【发布时间】:2019-02-09 18:57:03
【问题描述】:
我有产生一些消息的生产者(例如 10 条)。 有 n 个分区和一个具有 n 个消费者的消费者组。 Kafka 系统将在消费者之间分发消息。 如何将所有消费者的消息组合在一个地方,以便我有 10 条消息。 我正在使用带有 Spring 的 Kafka。
【问题讨论】:
-
How do I combine the messages of all the consumers in one place so that I have 10 messages这是什么意思?您是否尝试将这些数据保存在某个地方? -
其实我想拥有完整的数据用于下游处理。
-
如果您有同一组的消费者,那么您将获得下游的所有数据
标签: spring apache-kafka kafka-consumer-api