kafka实践一:手动修改消费偏移量的2种方式

工做中遇到过问题:包括数据Invalid Message和Failed_to_UNcompress等,会形成消费端的iterator损坏,致使消费进程挂掉,须要手动跳过某些数据;命令行 Kafka的偏移量有保存在zookeeper和kafka中topic(_consumer_offset)2种方式;3d 一、修改保存在zookeeper中的偏移量:server  使用./zkCli.sh -ser
相关文章
相关标签/搜索