kafka手動修改offset

今天在使用kafka時，原本須要將數據發送到topicA，卻將數據發送到了topicB，致使topicB的消費者組consumerB程序沒法消費topicB的內容，直接退出，所以須要手動修改partition的offset使lag等於0html 分區個數10個：htm 看了下網上關於這方面的資料很少，只找到了一個hortonworks上面的相對靠譜[1]，查看offset:kafka ./kafk

>>阅读原文<<