kafka實踐一：手動修改消費偏移量的2種方式

工做中遇到過問題：包括數據Invalid Message和Failed_to_UNcompress等，會形成消費端的iterator損壞，致使消費進程掛掉，須要手動跳過某些數據；命令行 Kafka的偏移量有保存在zookeeper和kafka中topic（_consumer_offset）2種方式；3d 一、修改保存在zookeeper中的偏移量：server  使用./zkCli.sh -ser

>>阅读原文<<