文章目录
1.概述
在文章 【kafka】kafka 消费速度 小于 日志清理速度 (kafka数据被清理了)会发生什么 auto.offset.reset 参数 中我们知道了,数据消费慢于清理时间会自动重置offset.
看下面这个现象。
首先设置kafka配置如下
offset.metadata.max.bytes=4096
offsets.commit.required.acks=-1
offsets.commit.timeout.ms=180000
offsets.load.buffer.size=