Apache Kafka如何向多个消费者组发送消息？
在Kafka文献中：
Kafka的处理方式不同。我们的主题被划分为一组完全有序的分区，每个分区在任何给定时间都由一个使用者使用。这意味着消费者在每个分区中的位置只是一个整数，即要消费的下一条消息的偏移量。这使得消耗量的状态非常小，每个分区只有一个数字。这种状态可以定期检查。这使得消息确认的等价物非常便宜。
然而，按照同一份文件中的快速入门指南，我很容易就能：
- 使用单个分区创建主题
- 创建一个游戏机制作人
- 推送几条消息
- 启动消费者消费
——从一开始 - 启动另一个消费者
——从头开始
并让两个消费者成功地从同一分区消费。
但这似乎与上述文件不符？
共有1个答案
当使用不同的消费者组时，消费者可以轻松地使用相同的分区。您可以将组id视为使用Kafka主题的不同应用程序。多个不同的应用程序可能希望以不同的方式使用Kafka主题中的数据，从而避免与其他应用程序冲突。这就是为什么两个消费者可能会使用一个分区（实际上是两个消费者使用一个分区的唯一方式）。
当你启动一个控制台消费者时，它会随机为它生成一个组ID（链接），因此这些消费者正在做我刚才写的事情。
-
由于消息需求的排序，我们有一个主题和一个分区。我们有两个消费者运行在不同的服务器上，具有相同的配置集，即groupId、consumerId和consumerGroup。即 1主题- 当我们部署消费者时，相同的代码会部署在两台服务器上。当消息到来时，我们会注意到两个消费者都在消费消息，而不是只有一个处理。让消费者在两台独立的服务器上运行的原因是，如果一台服务器崩溃，至少其他服务器可以继续处理消息。
-
问题内容： 我有一个JMS客户端，它正在生成消息并通过JMS队列发送到其唯一的使用者。 我想要的是不止一个消费者收到这些消息。我想到的第一件事是将队列转换为主题，以便现有用户和新用户都可以订阅并将相同的消息传递给他们。 显然，这将涉及在生产者和消费者方面修改当前的客户代码。 我还要查看其他选项，例如创建第二个队列，这样就不必修改现有的使用者。我相信这种方法有很多优点，例如（如果我错了，请纠正我）在
-
有以下消费者代码: 然后我用脚本生成消息: 问题是，当我将消费者作为两个不同的进程启动时，我会在每个进程中收到新消息。但是，我希望它只发送给一个消费者，而不是广播。 在Kafka的文献中(https://kafka.apache.org/documentation.html)其中写道： 如果所有使用者实例都具有相同的使用者组，则其工作原理就像在使用者之间平衡负载的传统队列一样。 我发现这些消费者的
-
我是ActiveMQ新手。我曾尝试在activemq中实现生产者-消费者（发送者-接收器）。在我的代码中，我很容易发送 这是我的制片人 MsgProducer。Java语言 MsgConsumer.java 有谁能帮我找出向多个消费者发送信息的方法吗。提前谢谢。
-
我们公司在Go中建立了push服务，为了保证传输速度，我们在四台机器上安装了push服务，当我们需要发送通知时，我们将消息发送给rabbitMQ，然后push服务从队列中获取消息，但有时我们发现只有一台机器获取消息。 我应该如何设置配置以确保每个消费者获得相同数量的消息？
-
TL；DR；我试图理解一个被分配了多个分区的单个使用者是如何处理reach分区的消费记录的。 例如： 在移动到下一个分区之前，会完全处理一个分区。 每次处理每个分区中的可用记录块。 从第一个可用分区处理一批N条记录 以循环旋转方式处理来自分区的N条记录 我找到了或分配程序的配置，但这只决定了使用者如何分配分区，而不是它如何从分配给它的分区中使用。 我开始深入研究KafkaConsumer源代码，#