如何修复“Kafka”消息延迟?

dbf7pr2w  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(350)

如何修复“Kafka”消息延迟?
如果“lag”的值没有下降,我认为消息在生成/消费中被延迟了。
有没有办法通过某些命令来更改设置或消除消息延迟?

fnvucqvd

fnvucqvd1#

如果“延迟不足”真的是指使用者滞后,那么需要增加处理数据的使用者的数量,但这可能会受到每个主题的分区数量的限制。您可以增加分区的数量,使使用者的数量等于分区的数量。您还可以更有效地重新实现消息处理层,因此它将在多个线程中处理数据,等等。

相关问题