下面是如何将kafka用作发布-订阅框架的一个很好的示例：https://github.com/abhioncbr/kafka-message-server/blob/master/readme.md我拼命寻找一个类似的例子，说明如何使用Kafka作为排队框架。这意味着一旦一个客户机检索到消息，其他客户机就不能访问它。
ozxc1zmp1#
答案在于消费者使用的组名。文件上说：如果所有使用者示例都有相同的使用者组，那么这就像传统的队列平衡使用者的负载一样。如果所有使用者示例都有不同的使用者组，那么这就像publish-subscribe一样工作，所有消息都广播给所有使用者。这回答了我的问题。
1条答案
按热度按时间ozxc1zmp1#
答案在于消费者使用的组名。文件上说：
如果所有使用者示例都有相同的使用者组，那么这就像传统的队列平衡使用者的负载一样。
如果所有使用者示例都有不同的使用者组，那么这就像publish-subscribe一样工作，所有消息都广播给所有使用者。
这回答了我的问题。