领导者经纪人在 kafka 中没有匹配的侦听器错误

一分耕耘，一分收获！既然都打开这篇《领导者经纪人在 kafka 中没有匹配的侦听器错误》，就坚持看下去，学下去吧！本文主要会给大家讲到golang等等知识点，如果大家对本文有好的建议或者看到有不足之处，非常欢迎大家积极提出！在后续文章我会继续更新Golang相关的内容，希望对大家都有所帮助！

问题内容

这个kafka错误是什么意思？

[2018-08-22 11:40:49,429] WARN [Consumer clientId=consumer-1, groupId=console-consumer-62114] 1 个分区具有没有匹配侦听器的领导代理，包括 [topicname-0] (org.apache. kafka.clients.NetworkClient)

我在运行时得到它：

./kafka-console-consumer.sh --topic topicname --bootstrap-server localhost:9094

在尝试阅读此主题时，我在 golang 程序中遇到了一些错误：

2018/08/22 11:44:12 ReadOffsetWithRetryOnError conn 错误： kafka0:9094 主题：0

代码片段：

conn, err := kafka.DialLeader(context.Background(), "tcp", ip, getTopic(topic), 0)
                if err != nil {
                    log.Println("ReadOffsetWithRetryOnError conn error:  ", ip, " topic:", topic)
                }

这很奇怪，因为在阅读不同主题时，它同时工作正常。

更多错误日志：

/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topicname Topic:indexBlock PartitionCount:1
ReplicationFactor:1 Configs: Topic: topicname Partition: 0 Leader: -1 Replicas: 1002 Isr: 1002

正确答案

[2018-08-22 11:40:49,429] WARN [Consumer clientId=consumer-1, groupId=console-consumer-62114] 1 个分区具有没有匹配侦听器的领导代理，包括 [topicname-0] (org.apache. kafka.clients.NetworkClient)

如果您尝试运行多个消费者并且 kafka 主题仅包含一个分区，也会发生此错误。一般来说，一个消费者应该映射到一个分区。如果您使用两个消费者，那么您应该在 kafka 主题中有 2 个分区。

以上就是《领导者经纪人在 kafka 中没有匹配的侦听器错误》的详细内容，更多关于golang的资料请关注golang学习网公众号！