我正在使用 Apache Storm 1.1.2 和 Kafka 0.11 在 Java 9 中構建 Spring 應用程序我注意到在高負載(每秒 2500 條消息)下,kafka spout 的延遲非常高。Kafka Spout 的并行度提示為 3。滯后幾乎等于 Spout Committed Offset。這個滯后設置了拓撲每秒可以攝取的最大消息量的上限,這不是很大。有誰知道解決方案?更新:我還注意到,即使有 10 個工人和 4 個并行提示,負載也不會在不同的 kafka spout 執行程序之間分配,我可以在 UI 中看到。主題有8個分區
Storm Kafka Spout 的延遲非常高
慕的地8271018
2021-10-27 10:32:07