kafka ha消费者设置

vq8itlhq 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(255)

我的应用程序使用来自kafka主题的消息，当我在我的环境中运行一个示例时，它可以正常工作，但是如果我运行多个示例，比如说3个示例（高可用性），那么我的应用程序的任何示例都不能使用来自主题的消息。
我有3个分区和1个复制因子。
当我跑的时候

./kafka-topics.sh --describe --zookeeper localhost:2181 --topic mytesttopic

Topic:mytesttopic     PartitionCount:3        ReplicationFactor:1     Configs:
    Topic: mytesttopic    Partition: 0    Leader: 0       Replicas: 0     Isr: 0
    Topic: mytesttopic    Partition: 1    Leader: 0       Replicas: 0     Isr: 0
    Topic: mytesttopic    Partition: 2    Leader: 0       Replicas: 0     Isr: 0

它给出了mytesttopic的上述配置。因此，我不确定在ha或多个消费者示例中使用来自kafka的消息缺少哪些步骤。

apache-kafka kafka-consumer-api

来源：https://stackoverflow.com/questions/47899823/kafka-ha-consumer-setup

1条答案

按热度按时间

6ss1mwsb1#

您应该验证您的所有kafka代理示例是否都在zookeeper上注册，当然它们具有不同的属性 broker.id .
您可以运行以下命令： /bin/zookeeper-shell.sh localhost:2181 ls /brokers/ids 在创建一个具有3个分区的新主题并运行 describe 命令时，应获得以下输出：

Topic: mytesttopic   PartitionCount:3    ReplicationFactor:1    Configs:
Topic: mytesttopic   Partition: 0    Leader: 2   Replicas: 2 Isr: 2
Topic: mytesttopic   Partition: 1    Leader: 0   Replicas: 0 Isr: 0
Topic: mytesttopic   Partition: 2    Leader: 1   Replicas: 1 Isr: 1

赞(0）回复(0）举报 2021-06-07

我来回答

kafka ha消费者设置

1条答案

相关问题

热门标签

最新问答