Spring-kafka遇到的消息重複消費問題

問題描述:kafka的某些topic在消費完畢後一段時間,重啓唯一消費者,offset會重置爲最小offset重新消費,一直導致kafka消費的重複消費問題。 問題產生原因:是offset信息過期導致的。我一直以爲消費者保持在線,最新位移信息是不會過期的。但即使消費者在線,位移信息也會如約過期。配置的數據保留時間log.retention.hours=168小時比位移保留時間offsets.ret
相關文章
相關標籤/搜索