0
我想重置與給定使用者相對應的先前偏移量。重置卡夫卡消費者的上一次偏移量
原因:我寫我的應用程序的spring-boot消費者代碼是使用「最早的」作爲自動偏移重置的值。由於現在偏移量已存儲在__consumer_offsets中,因此將自動偏移重置的值更改爲最新值不起作用。
注意:我使用的kafka版本高於0.9。不知道刪除使用者是否會有所幫助,因爲我知道偏移量現在存儲在主題__consumer_offsets中。
可以調用'KafkaConsumer.seek'復位偏移給定的分區。那是你要的嗎? – amethystic