在我公司的一個應用程序中，為了對稱為 LIVE 和 PRE-MATCH 的 2 組消息應用一些轉換，我們創建了 2 個 Kafka Streams，每個組一個。這兩個流都正確啟動，但是其中一個始終是按基于時間的順序創建的第二個流，不會進行任何更改：我的意思是它不會從開始主題中消耗任何內容。對日志的分析表明，主題和分區的配置肯定存在一些問題：2018-09-26 11:36:59,963 [INFO ] [] [StreamThread-2] [o.a.k.c.c.i.ConsumerCoordinator] - Setting newly assigned partitions [] for group Union2018-09-26 11:36:59,963 [INFO ] [] [StreamThread-1] [o.a.k.c.c.i.ConsumerCoordinator] - Setting newly assigned partitions [betgenius.integralfeed.live-0] for group Union正如您在上面的日志部分中看到的那樣，與 LIVE 提要關聯的 StreamThread-1 獲得了映射到正確源主題的分區的正確分配；在這種情況下與 PRE-MATCH 提要相關聯的 StreamThread-2 似乎收到了對空源主題的分區分配，實際上是不運行的。如果我人為地強制在 LIVE 之前創建 PRE-MATCH 流，情況就會相反。用于創建 2 個流的代碼完全相同，我只是更改了開始主題和結束主題。我的 Kafka 配置是否可能沒有足夠的可用資源？