我有一个kakfa集群，有3个kafka节点和3个zk节点。
生产商在aws机器上尝试将数据推送到运行在内部网服务器上的kafka集群上。
从控制台创建主题（作业\u aws \u 14）时
Partition: 0 Leader: 1 Replicas: 1 Isr: 1很好用。
但是主题（job\u aws\u 8）是用
Partition: 0 Leader: 2 Replicas: 2 Isr: 2它不起作用。
哪些设置出错以及如何更正。
请帮帮我。
# bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic JOB_AWS_14
Topic:JOB_AWS_14 PartitionCount:1 ReplicationFactor:1 Configs:
Topic: JOB_AWS_14 Partition: 0 Leader: 1 Replicas: 1 Isr: 1
# bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic JOB_AWS_8
Topic:JOB_AWS_8 PartitionCount:1 ReplicationFactor:1 Configs:
Topic: JOB_AWS_8 Partition: 0 Leader: 2 Replicas: 2 Isr: 2
1条答案
按热度按时间alen0pnh1#
您的制作者可以访问kafka node-1，它是主题“job\u aws\u 14”的负责人，因此您可以在访问主题“job\u aws\u 8”时生成指向该主题的消息。负责人是kafka node-2，而您的制作者可能无法访问node-2。确保您的生产者可以访问节点2。