kafka-1-消費者consumer無法消費的異常

  (1)異常現象： 服務器：record is corrupt（記錄損壞）不明原因，有可能磁盤空間不足導致，導致消費者無法正常消費消息，卡在某一個offset不能繼續消費。 (2)解決辦法： 先停掉消費者程序，殺掉進程（不可關閉kafka服務）然後手動設置偏移量，跳過卡在的offset位置。 進入kafka目錄，命令： bin/kafka-consumer-groups.sh --bootstr

>>阅读原文<<