我有一个producer,它生成一些消息(例如10条消息)。有n个分区和一个具有n个使用者的使用者组。Kafka系统将消息分发给消费者。如何将所有消费者的消息合并到一个地方,这样我就有10条消息了。我在用Kafka和Spring。
qv7cva1a1#
创建一个只有一个使用者的使用者组,然后您将从一个地方的所有分区中获取记录。
1条答案
按热度按时间qv7cva1a1#
创建一个只有一个使用者的使用者组,然后您将从一个地方的所有分区中获取记录。