春雲流Kafka反應流分區分配

Question

春雲流如何將多個Kafka分區分配給屬於同一個消費者組的反應流？

我注意到，如果我使用純粹的非反應流偵聽器，每個線程被分配到一個分區，這取決於使用者併發性配置。而在流（Flux輸入）的情況下，我沒有注意到任何這種平行行爲。似乎只有一個流被定義爲處理來自所有分區的消息。

我的期望是對每個Kafka主題分區都有單獨的流，即使是在不同線程備份的同一節點上也是如此。

Answer 1

感謝您的支持。我創建了一個問題來跟蹤此問題：https://github.com/spring-cloud/spring-cloud-stream/issues/980