这个kafka错误是什么意思?
[2018-08-22 11:40:49,429] WARN [Consumer clientId=consumer-1, groupId=console-consumer-62114] 1 partitions have leader brokers without a matching listener, including [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 error: < dial tcp :0: connect: connection refused > kafka0:9094 topic: 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 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 partitions have leader brokers without a matching listener, including [topicname-0] (org.apache.kafka.clients.NetworkClient)
如果您尝试运行多个消费者并且 kafka 主题仅包含一个分区,也会发生此错误。通常一个消费者应该映射一个分区。如果您使用两个消费者,那么您应该在 kafka 主题中有 2 个分区。
关于go - 卡夫卡中没有匹配的监听器错误的领导经纪人,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51966212/