【问题标题】:Bootstrap broker disconnected => KeeperErrorCode = NoNode for /brokers/topcis/xxxx/partitions/2/state + Key no found引导代理断开连接 => KeeperErrorCode = /brokers/topcis/xxxx/partitions/2/state 的 NoNode + 找不到密钥
【发布时间】:2019-10-19 00:32:07
【问题描述】:

我正在尝试为主题 XXX 运行 kafka-console-consume.sh

sh kafka-console-consumer.sh --bootstrap-server abcd:9092, bcde:9092, cdef:9092 --topic XXX

出现以下错误:

警告 clients.NetworkClient: Botstrapbroker abcd:9092 已断开连接

WARN clients.NetworkClient: Botstrapbroker bcde:9092 已断开

警告 clients.NetworkClient: Botstrapbroker cdef:9092 已断开

当我检查代理日志时,除了以下警告之外没有错误:

警告 nl.techop.kafka.dao.zookeeper.KafkaZkClient: KeeperErrorCode = /brokers/topics/XXX/partitions/2/state WARN 的 NoNode com.yammer.metrics.reporting.MetricsServlet:评估仪表时出错 java.util.NoSuchElementException:找不到键:[XXX,0]

我尝试过的:

我成功创建了一个 testing123 主题,如下所示:

    sh kafka-topics.sh --create --zookeeper defg:2181, dfde:2181, cdef:2181
--replication-factor 3 --partitions 3 --topic testing123

但是,当我尝试使用 kafka-console-producer.sh 时,会发生同样的错误:

sh kafka-console-producer.sh --broker-list abcd:9092, bcde:9092, cdef:9092

警告 clients.NetworkClient:Botstrap 代理 abcd:9092 已断开连接
警告 clients.NetworkClient: Botstrap 代理 bcde:9092 已断开连接
WARN clients.NetworkClient: Botstrap 代理 cdef:9092 已断开连接

【问题讨论】:

  • 我假设您启用了身份验证,对吧?
  • kafka-console-producer 需要你指定一个--topic... 请显示完整的命令,你真的只需要一个服务器来连接,并不是所有的都是必需的。但是,您应该确保 Kafka 确实在运行。

标签: apache-kafka kafka-consumer-api


【解决方案1】:

谢谢大家。

集群已启用 Kerberos。

我通过将以下内容添加到我的 consumer.config 属性文件中解决了这个问题:

  • group.id = 水槽
    security.protocol=SASL_PLAINTEXT
    sasl.kerberos.service.name=kafka sasl.mechanism=GSSAPI
    ssl.client.auth=none

然后在下面运行:

sh kafka-console-consumer.sh --bootstrap-server abcd:9092, bcde:9092, cdef:9092 --topic XXX --consumer.config /xxx/xxx/xxx/consumer.config.properties

【讨论】:

    猜你喜欢
    • 2015-01-08
    • 1970-01-01
    • 2018-11-06
    • 2016-11-22
    • 1970-01-01
    • 1970-01-01
    • 2018-02-16
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多