如何解决卡夫卡消费者滞后在0.10.2.1 kafka

作者: ikun
发布时间: 2024-07-19 04:39:23 (12天前)
转自：

3 条回复

0#
回复此人
不浪漫 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 重新启动消费者不太可能解决问题。我建议采取以下一系列行动： </p> <UL> <LI> <P> 监控每个消费者在单位时间（每分钟，我们假设）中减少多少延迟。您可以通过将滞后总减少量除以6来推导出它。 </p> </LI> <LI> <P> 如果滞后减少的速度仍然太低，并且您想增加它，那么添加适当数量的消费者。您可以估算上一步中的其他消费者数量。 </p> </LI> <LI> <P> 确保所有消费者都在同一个消费者群体中。 </p> </LI> </UL> </DIV>

编辑
1#
回复此人
十二* | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <OL> <LI> 大多数经纪人实例的表现远高于消费者。如何增加主题的分区，并增加消费者到分区。使用并发可以提高性能。 </LI> <LI> 如果您在zookeeper上存储偏移量，则可能是瓶颈。如果可能的话，减少偏移的提交并使用专用的zookeeper。最好的解决方案是在经纪人处存储抵消。 </LI> </醇> </DIV>

编辑

登录后才能参与评论