kafka手动修改消费者偏移量

1.创建一个测试主题：html [root@snn bin]#./kafka-topics.sh --zookeeper snn:2181 --topic offset-test --partitions 2 --replication-factor 2 –createbootstrap 检查主题的设置状况：测试 [root@snn bin]#./kafka-topics.sh --zookeep

>>阅读原文<<