是否将消息传递给每组一个消费者？
我有两个消费群体，即G1和G2。
-
null
类似地，当G2轮询后，它仍然会找到关于主题的消息。这里还枯萎M3或M4会收到消息吗？
我也相信所有的成员都应该在同一个节点上。对吧？客户端代码或Kafka的责任是选择一个组中的特定成员吗？
共有1个答案
您的问题的答案取决于这些消费者组正在消费的主题中有多少分区。使用者组中只有一个成员可以从主题的每个分区中读取。
如果主题T1中只有一个分区，那么M1和M3将从该分区读取，而M2和M4将没有消息。
如果T1中有两个分区（例如P1和P2)，则M1和M3将从T1P1获得消息，M2和M4将从T1P2获得消息
消费者组的所有成员不必位于同一节点上
其中一个代理被指定为组的协调者，负责管理组的成员以及他们的分区分配。
-
我有两个组id相同的消费者服务器订阅了相同的主题。kafka服务器仅使用一个分区运行。据我所知，消息应该在这两个消费者服务器中随机使用。但现在似乎总是同一个消费者服务器A消费消息，另一个不消费消息。如果我停止消费者服务器A，另一个将正常工作。我所期望的是，他们可以随机消费信息。
-
FCM服务未向我的iOS应用程序发送消息。 > App CAN成功接收APNs令牌和实例ID令牌 App CAN使用推送通知实用程序利用. p8令牌在后台成功接收来自APN的推送 #2中使用的相同APNs密钥上传到Firebase控制台 应用程序无法接收Firebase控制台中Notification Composer发送的消息，也无法使用CURL请求接收消息。 应用程序在通过FCM发送时不显示任
-
我正在尝试用Java实现一个简单的生产者-->Kafka-->消费者应用程序。我能够成功地生成和使用消息，但是当我重新启动消费者时，问题就出现了，其中一些已经使用的消息再次被消费者从Kafka中拾取（不是所有的消息，而是最近使用的一些消息）。 我已在我的使用者中设置了，并且我的属性设置为1000毫秒。 “重新传递一些已使用的消息”是一个已知的问题，还是有任何其他设置，我没有在这里？ 基本上，有没有
-
高层体系结构 JMS（生产者/消费者）<---->Artemis(STOMP)<---->Websocket-Broker-Relay-Service<---->STOMP-over-Websocket-client（生产者/消费者）
-
本文向大家介绍Kafka 消费者是否可以消费指定分区消息？相关面试题，主要包含被问及Kafka 消费者是否可以消费指定分区消息？时的应答技巧和注意事项，需要的朋友参考一下 Kafa consumer消费消息时，向broker发出fetch请求去消费特定分区的消息，consumer指定消息在日志中的偏移量（offset），就可以消费从这个位置开始的消息，customer拥有了offset的控制权，可
-
我试图提出一个设计，使用Kafka为多个处理代理并行处理来自Kafka主题的消息。 null 或者还有什么我遗漏的地方可能有助于我对这一点的理解？