运维开发网

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

运维开发网 https://www.qedev.com 2020-04-15 16:43 出处:网络 作者:运维开发网整理
这个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
这个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

我认为我的问题是我运行了2个实例,没有为复制设置任何特殊内容. (问题没有复制?)然后我删除了一个经纪人.一些主题停止了工作.

扫码领视频副本.gif

0

精彩评论

暂无评论...
验证码 换一张
取 消

关注公众号