Spring Cloud 流如何将多个Kafka分区分配给属于同一个用户组的反应流？
我注意到，如果我使用普通的非反应流监听器，则每个线程都会分配给一个分区，具体取决于消费者并发配置 . 然而，在流（Flux输入）的情况下，我没有注意到任何这样的并行行为 . 似乎只定义了一个流来处理来自所有分区的消息 .
我的期望是为每个Kafka主题分区提供单独的流，即使在由不同线程备份的同一节点上也是如此 .
谢谢你提出来 . 我创建了一个跟踪此问题的问题：https://github.com/spring-cloud/spring-cloud-stream/issues/980
1 回答
谢谢你提出来 . 我创建了一个跟踪此问题的问题：https://github.com/spring-cloud/spring-cloud-stream/issues/980