java kafka多节点设置activeActive
我刚接触卡夫卡,有一些基本的疑问。 我正在尝试进行多节点卡夫卡设置(活动)。以下是场景:-
- 运行单个zookeeper(端口:2181)
- 开办了三家卡夫卡经纪公司(909290939094)
- 创建单个主题测试(分区:1,复制3)
- 已使用代理列表启动生产者(90929093)
- 从909290939094开始使用consumer,但他们都使用相同的主题李>
现在我的疑问是,当我从制作人那里发送一条信息时,这三个消费者都在使用它
问题1。这是否意味着它在复制信息
问题2。由于生产者在90929093上运行,那么为什么端口9094上的消费者在使用该消息?是因为它使用了相同的主题名称吗
第三季度。我如何确保当我从生产者发送消息时,它应该由单个消费者消费?(我尝试分组,但如果任何消费者在不同的组中,则它正在接收消息。)
第四季度。如果我想在消费者之间分发信息,我如何才能做到这一点
问题5。有没有其他方法可以设置具有单个生产者和多个消费者的多节点卡夫卡(活动-活动)
感谢您的帮助
# 1 楼答案
我在评论中回答了这个问题,但这实际上是一个对卡夫卡消费群体缺乏了解的问题。这太长了,无法以这种形式讨论,因此我将在这里指导您https://kafka.apache.org/documentation/#theconsumer