我有一个kakfa集群,有3个kafka节点和3个zk节点 .
生产环境 者在AWS机器上试图在我的Intranet服务器上运行的kafka集群上推送数据 . 当从具有分区的控制台创建主题(JOB_AWS_14)时:0领导者:1个副本:1个Isr:1它工作正常 .
但是使用分区创建主题(JOB_AWS_8):0领导者:2个副本:2个Isr:2它无法正常工作 . 哪些设置出错以及如何纠正 .
请帮我 .
] #bin / kafka-topics.sh --describe --zookeeper localhost:2181 --topic JOB_AWS_14主题:JOB_AWS_14 PartitionCount:1 ReplicationFactor:1配置:主题:JOB_AWS_14分区:0领导:1个副本:1个Isr:1
bin / kafka-topics.sh --describe --zookeeper localhost:2181 - topic JOB_AWS_8
主题:JOB_AWS_8 PartitionCount:1 ReplicationFactor:1配置:主题:JOB_AWS_8分区:0领导者:2个副本:2个Isr:2
谢谢 . 〜希亚姆
1 回答
您的 生产环境 者可以访问Kafka node-1,它是主题“JOB_AWS_14”的领导者,因此您可以在访问主题“JOB_AWS_8”主题为Kafka node-2并且您的 生产环境 者可能无法访问节点时生成该主题的消息2 . 确保您的 生产环境 者可以访问node-2 .