返回到文章

采纳

编辑于

kafka的某些topic在消费完毕后一段时间重启唯一消费者会重置为最小offset重新消费?

kafka

版本配置:

kafka版本为kafka_2.10-0.10.2.0,单broker单分区单消费者,log.retention.hours设置为168。结合spring-kafka使用,consumer的group.id不变,auto.offset.reset设置为earliest,client.id未指定,由spring-kafka自动生成。enable.auto.commit设置为false,手动提交offset。

问题描述:

在消费数据完毕后,使用命令./kafka-consumer-groups.sh --bootstrap-server localhost:9094 --describe --group group-name 查询到的topic的lag为0.不做任何更改,即时重启消费者,无异常。等过了约一天到两天再进行重启,部分topic会重置为最小offset重新消费。。。查询到生成的client.id是同一个。

命令删除过topic,但问题还是会出现。求大佬指教。