使用了自動(dòng)提交

如果自動(dòng)提交的偏移量小于客戶端處理的最后一個(gè)消息的偏移量，那么處于兩個(gè)偏移量之間的消息就會(huì)被重復(fù)處理，

假設(shè)我們采用了自動(dòng)提交，且提交時(shí)間間隔為5s，在最近一次提交之后的3s發(fā)生了再均衡，再均衡之后，消費(fèi)者從最后一次提交的偏移量位置開始讀取消息。這個(gè)時(shí)候偏移量已經(jīng)落后了3s，所以在這3s內(nèi)到達(dá)的消息會(huì)被重復(fù)處理。可以通過修改提交時(shí)間間隔來更頻繁地提交偏移量，減小可能出現(xiàn)重復(fù)悄息的時(shí)間窗，不過這種情況是無也完全避免的。