Storm消費Kafka異常 - topic其中兩個分區達到某個值不進行消費，持續阻塞

Kafka消費storm，突然有兩個分區無法消費數據(或重複消費無法提交offset) offset是我們自己進行管理，kafka日誌也是正常沒有報錯，storm日誌也是沒有報錯~ 就是卡住了 1.嘗試將partition爲0,1的offset記錄刪除，重新跑一遍，結果還是到那個offset處卡住 2.再次嘗試手動修改offset跳過卡住的那一條數據(這種做法會丟失一條數據,在數據不允許丟失或無法

>>阅读原文<<