Kafka常見問題

1. 如果想消費已經被消費過的數據,如何實現? consumer是底層採用的是一個阻塞隊列,只要一有producer生產數據,那consumer就會將數據消費。當然這裏會產生一個很嚴重的問題,如果你重啓一消費者程序,那你連一條數據都抓不到,但是log文件中明明可以看到所有數據都好好的存在。換句話說,一旦你消費過這些數據,那你就無法再次用同一個groupid消費同一組數據了。 原因:消費者消費了數據
相關文章
相關標籤/搜索