【发布时间】: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