如何修复"kafka"消息延迟？

Question

如何修复"kafka"消息延迟？

如果"滞后"的值没有下降，我认为消息在生成/消费中延迟。

有没有办法更改设置或使用某些命令消除消息延迟？

Answer 1

如果在延迟下，您真的意味着使用者滞后，那么您需要增加处理数据的使用者数量，但这可能会受到每个主题的分区数量的限制。 您可以增加分区数，并使使用者数等于分区数。您还可以以更有效的方式重新实现消息处理层，因此它将在多个线程中处理数据，等等。