【发布时间】：2017-06-03 14:33:21
【问题描述】：
Spring Cloud Stream 如何将多个 Kafka 分区分配给属于同一消费者组的响应式流？
我注意到，如果我使用普通的非反应式流侦听器，每个线程都会被分配到一个分区，具体取决于消费者并发配置。然而，在流（通量输入）的情况下，我没有注意到任何这种并行行为。似乎只定义了一个流来处理来自所有分区的消息。
我的期望是每个 Kafka 主题分区都有单独的流，即使在由不同线程备份的同一节点上也是如此。
【问题讨论】：
标签： apache-kafka spring-integration spring-cloud-stream