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

Question

这个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年8月22日11点44分12秒ReadOffsetWithRetryOnError康恩错误:<拨TCP:0:连接:连接被拒绝> kafka0:9094主题:0

代码段:

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

这很奇怪,因为在阅读不同的主题时,它同时工作正常.

更多错误日志:

/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topicname主题:indexBlock PartitionCount:1
ReplicationFactor:1配置:主题:topicname分区:0领导者:-1副本:1002 Isr:1002

Answer 1

[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 个分区。