有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java kafka多节点设置activeActive

我刚接触卡夫卡,有一些基本的疑问。 我正在尝试进行多节点卡夫卡设置(活动)。以下是场景:-

  1. 运行单个zookeeper(端口:2181)
  2. 开办了三家卡夫卡经纪公司(909290939094)
  3. 创建单个主题测试(分区:1,复制3)
  4. 已使用代理列表启动生产者(90929093)
  5. 从909290939094开始使用consumer,但他们都使用相同的主题

现在我的疑问是,当我从制作人那里发送一条信息时,这三个消费者都在使用它

问题1。这是否意味着它在复制信息

问题2。由于生产者在90929093上运行,那么为什么端口9094上的消费者在使用该消息?是因为它使用了相同的主题名称吗

第三季度。我如何确保当我从生产者发送消息时,它应该由单个消费者消费?(我尝试分组,但如果任何消费者在不同的组中,则它正在接收消息。)

第四季度。如果我想在消费者之间分发信息,我如何才能做到这一点

问题5。有没有其他方法可以设置具有单个生产者和多个消费者的多节点卡夫卡(活动-活动)

感谢您的帮助


共 (1) 个答案