max.poll.records：一次poll返回訊息的最大條數，預設是500條
connection.max.idle.max：consumer跟broker的socket連線如果空閒超過了一定的時間就會自動**連線，下次消費就要重新建立socket連線，這個建議設定為-1，不要去**
enable.auto.commit：開啟自動提交偏移量
auto.commit.interval.ms：每隔多久提交一次偏移量，預設值為5000ms 也就是5s
auto.offset.reset：
kafka消費者之seek方法
rotected static properties initconfig public static void main string args for topicpartition tp assignment while isrunning.get 上面的情形是我們知道具體的消費位置，如果我們不...
kafka消費者之seek方法
rotected static properties initconfig public static void main string args for topicpartition tp assignment while isrunning.get 上面的情形是我們知道具體的消費位置，如果我們不...
kafka消費者無法消費異常
今天被乙個kafka消費異常折磨了一天，頭差點炸了，還好最後解決了它 異常 伺服器 record is corrupt 記錄損壞 不明原因 有可能磁碟空間不足導致 導致消費者無法正常消費訊息 卡在某乙個offset 不能繼續消費 解決辦法 先停掉消費者程式 殺掉程序 不可關閉kafka服務 然後手動...