leader代理

ylamdve6  于 2021-06-07  发布在  Kafka
关注(0)|答案(6)|浏览(283)

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

gorkyyrv

gorkyyrv1#

在我的例子中,我在测试时遇到了这个错误 Kafka 故障转移。我击落了1个 Kafka ,并希望将消息写入另一个 Kafka .
问题就是这个主题 replication-factor 设置为1,当我需要设置为2时(Kafka2例)

奖金

查看创建这两个主题的目录(在我的例子中:kafka logs xx) Kafka ,你就会明白为什么:-)

myzjeezk

myzjeezk2#

我想我的问题是我运行了2个示例,没有为复制设置任何特殊的设置(可能没有复制?)然后我删除了一个代理。有些主题停止工作。

f0ofjuux

f0ofjuux3#

我遇到了这个问题,我通过创建一个新的代理并启动它来解决它。之后,您必须重新启动不同的消费者、生产者等。

7d7tgy0s

7d7tgy0s4#

在我的例子中,我在将kafka集群从v2.0更新到v2.4时遇到了这个错误。原因是server.properties文件中log.dirs的配置设置错误。因为我没有注意到不同节点的磁盘名不同,而且我在log.dirs设置中错误地匹配了磁盘名。

svmlkihl

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主题中应该有两个分区。

txu3uszq

txu3uszq6#

跳转猴子的奖金检查目录是有帮助的。对我来说,我和比特纳米·Kafka在一起。在第一次部署时我不是 config 在舵值中。我想将保留时间改为分钟,并设置为:

config: |-
  log.retention.minutes=10

这导致了 log.dirs 要从中切换的目录 /bitnami/kafka/data/tmp/logs .
从本质上讲,数据存储在kafka代理上导致错误出现。

相关问题