公司最近的kafka集群消息堆积达到了2.8T,不知道从那些角度去排查问题。6个parthition,6个replicas。
kafka的消息是落磁盘的,默认是保留7天(无论你是否消费)。
log.retention.hours=168
配置参考来自:Kafka Broker配置
所以是没有积压这回事,超过7点的消息会滚动清理,所以就是要关注一下,7天接收到的消息,别超过你的磁盘就好了。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
kafka的消息是落磁盘的,默认是保留7天(无论你是否消费)。
log.retention.hours=168
配置参考来自:Kafka Broker配置
所以是没有积压这回事,超过7点的消息会滚动清理,所以就是要关注一下,7天接收到的消息,别超过你的磁盘就好了。
你的答案