kafka修改指定消费组的偏移量

kafka针对每一个消费组的消费信息都在zookeeper中作了记录，启动一个zookeeper客户端，如下能够看出kafka每一个消费组在zookeeper中的消费每一个kafka主题的信息 [zk: localhost:2181(CONNECTED) 0] ls /consumers/kafkawarning0 kafkawarning02 （消费组groupid） kafkawarni

>>阅读原文<<