Kafka+此服务器不是该主题的领导者-分区+Kafka生产者
我们从每个3kafka机器的server.log中得到了许多错误（集群中有3kafka）
[2019-12-05 13:25:09,529] ERROR [ReplicaFetcherThread-0-1], Error for partition [jdty.dee.rules.time,91] to broker 1001:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2019-12-05 13:25:09,529] ERROR [ReplicaFetcherThread-0-1], Error for partition [jdty.dee.export.profiles,96] to broker 1001:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2019-12-05 13:25:09,529] ERROR [ReplicaFetcherThread-0-1], Error for partition [jdty.dee.control.tt.state,40] to broker 1001:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
[2019-12-05 13:25:09,529] ERROR [ReplicaFetcherThread-0-1], Error for partition [jdty.dee.control.tt,67] to broker 1001:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)
根据我的理解，每个主题都由一个或多个经纪人服务--一个是领导者，其余的经纪人是追随者。
共有1个答案
追随者经纪人从领导者经纪人那里获取（领导者不推动追随者）。因此，似乎一个追随者经纪人试图从错误的（领导者）经纪人那里获取信息。这可能发生的是一个分区的领导者改变了。相应的跟随者代理应自动更新其集群元数据，以重新发现新的领导者。如果错误持续存在，则表示此跟随者代理在更新其元数据时存在问题。
-
可能是Kafka的复制品——该服务器不是该主题分区的领导者，但没有公认的答案，也没有明确的解决方案。 我有一个简单的java程序来向Kafka传达信息： 我得到了以下例外： 当我尝试使用时，我得到以下错误： 当我描述我的主题时，我有以下信息： 我试着创建一个新的主题，并按照《快速入门指南》中提到的那样生成消息，然后上述步骤都很有效。 我应该在或producer configuration（生产者配
-
我正在努力通过SSL移动所有Kafka流量。每个区域有两个集群。 使用Kafka 2.7.0版。 除一个集群外，所有区域和所有集群都可以通过SSL正常工作。 在其他工具中，我使用< code>kafkacat来探测集群。 当通过明文连接对此集群执行时，它会列出所有代理、主题和分区，并显示每个分区的领导者： 当通过 SSL 执行相同的命令时，会发现： 0经纪人 列出主题和分区，但没有标题 对该地区的
-
我使用的是spring-kafka 2.1.10.release。我有一个拥有next属性的消费者（复制了几乎所有的属性）： 我生产的Apache Kafka版本是2.11-1.0.0-0pan4。有一个集群内部有3个kafka的节点： 甚至无法在本地复制。事情是这样的： 4）最神秘：在应用程序中，一切都可以工作。Spring-consumer读取新消息并将它们发送给kafka。我看到了这样的日志
-
假设我有一个名为“MyTopic”的主题，它有3个分区P0、P1和P2。这些分区中的每一个都有一个leader，并且本主题的数据（消息）分布在这些分区中。 1.Producer将始终根据代理上的负载以循环方式写到分区的领导者。对吗？ 2.制作人如何认识隔断的首领？
-
Kafka主题分区偏移位置始终从0或随机值开始，如何确保使用者记录是分区中的第一条记录？有没有办法找出答案？如果有的话，请让我知道。谢谢。
-
我正在创建一个系统，其中前端服务将消息推送到Kafka请求主题，并为一些下游后端消费者（实际上是一个最终推送回Kafka的复杂系统）监听另一个响应主题，以处理请求消息并最终推进到“回应”话题。 我试图找出最优雅的方法来确保消费者监听适当的分区并收到响应，并且后端推送到前端消费者正在监听的分区。我们总是需要确保响应到达产生初始消息的同一个消费者。 到目前为止，我有两种解决方案，但都不是特别令人满意的