Kafka的错误是什么意思?
[2018-08-22 11:40:49429]警告[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连接错误:<拨号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—描述—Zookeeperlocalhost:2181 --topic 主题名称topic:indexblock partitioncount:1
复制ionfactor:1 configs:主题:topicname分区:0引线:-1副本:1002 isr:1002
6条答案
按热度按时间gorkyyrv1#
在我的例子中,我在测试时遇到了这个错误
Kafka
故障转移。我击落了1个Kafka
,并希望将消息写入另一个Kafka
.问题就是这个主题
replication-factor
设置为1,当我需要设置为2时(Kafka2例)奖金:
查看创建这两个主题的目录(在我的例子中:kafka logs xx)
Kafka
,你就会明白为什么:-)myzjeezk2#
我想我的问题是我运行了2个示例,没有为复制设置任何特殊的设置(可能没有复制?)然后我删除了一个代理。有些主题停止工作。
f0ofjuux3#
我遇到了这个问题,我通过创建一个新的代理并启动它来解决它。之后,您必须重新启动不同的消费者、生产者等。
7d7tgy0s4#
在我的例子中,我在将kafka集群从v2.0更新到v2.4时遇到了这个错误。原因是server.properties文件中log.dirs的配置设置错误。因为我没有注意到不同节点的磁盘名不同,而且我在log.dirs设置中错误地匹配了磁盘名。
svmlkihl5#
[2018-08-22 11:40:49429]警告[consumer clientid=consumer-1,groupid=console-consumer-62114]1分区具有没有匹配侦听器的主代理,包括[topicname-0](org.apache.kafka.clients.networkclient)
如果您尝试运行多个使用者并且kafka主题仅包含一个分区,则也会发生此错误。通常,一个使用者应该Map一个分区。如果您使用的是两个使用者,那么在kafka主题中应该有两个分区。
txu3uszq6#
跳转猴子的奖金检查目录是有帮助的。对我来说,我和比特纳米·Kafka在一起。在第一次部署时我不是
config
在舵值中。我想将保留时间改为分钟,并设置为:这导致了
log.dirs
要从中切换的目录/bitnami/kafka/data
至/tmp/logs
.从本质上讲,数据存储在kafka代理上导致错误出现。