如何修复“Kafka”消息延迟?如果“lag”的值没有下降,我认为消息在生成/消费中被延迟了。有没有办法通过某些命令来更改设置或消除消息延迟?
fnvucqvd1#
如果“延迟不足”真的是指使用者滞后,那么需要增加处理数据的使用者的数量,但这可能会受到每个主题的分区数量的限制。您可以增加分区的数量,使使用者的数量等于分区的数量。您还可以更有效地重新实现消息处理层,因此它将在多个线程中处理数据,等等。
1条答案
按热度按时间fnvucqvd1#
如果“延迟不足”真的是指使用者滞后,那么需要增加处理数据的使用者的数量,但这可能会受到每个主题的分区数量的限制。您可以增加分区的数量,使使用者的数量等于分区的数量。您还可以更有效地重新实现消息处理层,因此它将在多个线程中处理数据,等等。