Kafka如何处理运行速度比其他消费者慢的消费者？

Kafka并不真正关心消息的消耗速度。它甚至不涉及有多少消费者或每条消息被读取多少次。Kafka只是将消息提交到分区，并在配置的时间使它们过期。

消费者群体有责任确保消息被及时且均匀地阅读。在您的情况下，您有两个问题：一组分区的读取滞后，然后处理来自这些分区的消息滞后。

对于主题中消息的实际消耗，您必须使用Kafka元数据API来跟踪每个使用者面对的相对负载，无论是通过偏斜分区还是由于使用者以不同的速度运行。您要么必须重新分配分区给使用者，以使速度较慢的使用者减少工作量，要么随机地将使用者重新分配给分区，以期最终随着时间的推移平衡工作量。

为了更好地平衡消息的处理，应该从消息的处理中排除对消息的读取-类似于Storm流模型。您仍然必须以编程方式监视积压到处理逻辑中，但是您可以将工作移至更快的节点以平衡工作。