单个Kafka消费者同时使用来自两个不同集群的消息
有没有任何选项或配置可以方便单个Kafka消费者同时消费来自两个不同集群的消息？在创建生产者和消费者时，我将两个集群都提到逗号分隔。我一直在观察消费者只消费来自单个集群的消息。
请参阅下面的说明：消费者C1被配置为监听集群：集群-1：Zooker-1 with Broker-1集群-2：Zooker-2 with Broker-2
我正在寻找一种解决方案，其中消费者C1可以同时消费来自集群1和集群2的消息。
共有1个答案
无法使用来自两个或多个不同群集的数据。Kafka使用者的任何实例只能使用来自单个Kafka集群的消息。
-
我有两个Kafka集群说A和B，B是A的复制品。仅当 A 关闭且相反，我才希望使用来自集群 B 的消息。然而，使用来自两个集群的消息会导致重复的消息。那么，有什么办法可以将我的 kafka 使用者配置为仅从一个集群接收消息。 谢谢-
-
我有4个分区和4个消费者(例如A、B、C、D)。如何使用使用者组配置哪个使用者将从哪个分区读取数据。我用的是Kafka的春靴。
-
我以前认为设置我的消费者将始终收到他们尚未收到的消息，但最近我发现情况并非如此。这只在使用者尚未提交抵消时才起作用。在任何其他情况下，使用者将继续接收偏移大于其提交的最后偏移的消息。 由于我总是使用随机的组ID创建新的使用者，我意识到我的使用者“没有内存”，他们是新的使用者，并且他们永远不会提交偏移，因此策略将始终适用。我的疑虑就从这里开始了。假设以下场景： 我有两个客户端应用程序，A和B，每个客
-
我有一个场景，我已经在不同的节点上部署了4个Kafka消费者实例。我的主题有4个分区。现在，我想配置消费者，使他们都从主题的不同分区获取。 我知道一个事实，如果消费者来自同一个消费者组，他们会确保分区被平分。但在我的情况下，他们不在同一组。
-
在我的Spring Boot Kafka应用程序中，我有以下使用者配置： 消费者： 如果我理解正确的话，现在我有一个消费者的实例。我想增加post消费者的数量，假设有5个消费者将消费来自${kafka.topic.post.send}的不同（不同）消息，以加快消息消费。 它是否像添加工厂一样简单。setConcurrency（5） 至我的PostKafkAlisterContainerFactor
-
我有两个jms消费者，每个都在不同的流中。我想使用另一个流来聚合这两条消息的消息。并且还需要保留相关ID，因为我需要分割有效负载并发送回消息。 我尝试将分散收集与两个入站 VM 一起使用，但收到以下错误： 由以下原因导致：组织.xml.sax.SAXParse 异常：cvc-complex-type.2.4.a：发现以元素“vm：入站终结点”开头的无效内容。“{”http://www.muleso