0

我有一个带有 3 个 kafka 节点和 3 个 zk 节点的 kakfa 集群。

生产者在 AWS 机器上，试图将数据推送到我的内部网服务器上运行的 kafka 集群上。

当从控制台创建主题（JOB_AWS_14）时

Partition: 0    Leader: 1       Replicas: 1     Isr: 1

它工作正常。

但是在哪里创建了一个主题（JOB_AWS_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
4

1 回答 1

0

您的生产者可以访问 Kafka 节点 1，它是主题“JOB_AWS_14”的领导者，因此您可以在主题“JOB_AWS_8”领导者是 Kafka 节点 2 时向该主题生成消息，并且您的生产者可能无法访问节点- 2. 确保您的生产者可以访问节点 2。

于 2016-02-17T16:56:34.080 回答