flume消費kafka消息的offset查看方法

kafka版本1.0.1 flume版本1.8.0   offset已經不在zookeeper存儲了，存儲在__consumer_offsets這個topic裏面，具體哪個consumer group存儲在這個topic的哪個partition裏面通過下面計算方法確定： public class HelloWorld { public static void main(String[] args)

>>阅读原文<<