来自不同群体的Kafka消费者来自不同的主题划分
我有一个场景，我已经在不同的节点上部署了4个Kafka消费者实例。我的主题有4个分区。现在，我想配置消费者，使他们都从主题的不同分区获取。
我知道一个事实，如果消费者来自同一个消费者组，他们会确保分区被平分。但在我的情况下，他们不在同一组。
共有1个答案
为了实现你想要的，你需要消费者在同一个消费者群体中。只有在这种情况下，才会应用“竞争消费者”模式：每个消费者从4个分区接收1个分区，因此您有4个消费者，每个消费者从1个分区读取数据并接收该分区的消息。当使用者是不同使用者组的一部分时，每个使用者将被分配到所有4个分区，以发布/订阅方式接收来自所有使用者的消息。
-
我有4个分区和4个消费者(例如A、B、C、D)。如何使用使用者组配置哪个使用者将从哪个分区读取数据。我用的是Kafka的春靴。
-
有没有任何选项或配置可以方便单个Kafka消费者同时消费来自两个不同集群的消息？在创建生产者和消费者时，我将两个集群都提到逗号分隔。我一直在观察消费者只消费来自单个集群的消息。 请参阅下面的说明：消费者C1被配置为监听集群：集群-1：Zooker-1 with Broker-1集群-2：Zooker-2 with Broker-2 我正在寻找一种解决方案，其中消费者C1可以同时消费来自集群1和集群
-
我们使用Akka流Kafka来生成和消费消息和Strimzi Kafka集群。以下是相关版本： 重构消息发出后，消费者停止工作。我们在主题中确实有一些信息，但消费者只是在无休止地等待。 以下是日志片段： 还有一些要点： 架构注册表配置正确且良好（否则生产者将无法工作）。 主题（和组协调器）很好，我可以通过这样的普通消费者消费消息： 这就是代码卡住的地方——我使用阻塞调用获取2条消息（甚至无法获取1
-
生产者发送消息到一个有四个分区的主题。我们有一个消费者在消费来自这个主题的消息。应用程序在工作日一直运行周末例外：它不会在周末期间调用poll方法。 使用者配置：自动提交，自动提交时间为5s（默认）。 应用程序一直运行良好，直到一个星期天，当它重新开始调用poll方法。我们看到有数百万条消息从这个话题中被轮询出来。消费者基本上是轮询来自主题的所有消息。将新的偏移量与它在周末停止之前的偏移量进行比较
-
D： \软件\Kafka\Kafka2.10-0.10.0.1\bin\windows 我使用上面的命令来消费消息，有什么我错过的吗？帮助我： 这个 那些是生产者和消费者......
-
我正在阅读Kafka常见问题解答，他们如下所示。 •每个分区不会被每个使用者组中的多个使用者线程/进程使用。这允许每个进程以单线程方式使用，以保证分区内的使用者的顺序（如果我们将有序消息分割成一个分区并将它们传递给多个使用者，即使这些消息是按顺序存储的，它们有时也会被无序地处理）。 有没有可能，