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

>>阅读原文<<