KAFKA常用命令

指定偏移量消费
bin/kafka-consumer-groups.sh --bootstrap-server xx.xx.xx.184:9092,xx.xx.xx.185:9092,xx.xx.xx.186:9092 --group server --topic topic-1 --execute --reset-offsets --to-offset 80

指定topic消费
bin/kafka-console-consumer.sh --bootstrap-server xx.xx.xx.184:9092,xx.xx.xx.185:9092,xx.xx.xx.186:9092 --topic topic-2  --group server --skip-message-on-error

指定分区消费
bin/kafka-console-consumer.sh --bootstrap-server xx.xx.xx.184:9092,xx.xx.xx.185:9092,xx.xx.xx.186:9092 --topic topic-1 --partition 3 --group server --skip-message-on-error

./kafka-topics.sh --describe --zookeeper xx.xx.xx.64:2181,xx.xx.xx.55:2181,xx.xx.xx.38:2181 --topic aqjk_4

sh kafka-topics.sh --list --zookeeper xx.xx.xx.64:2181,xx.xx.xx.55:2181,xx.xx.xx.38:2181

 ./kafka-topics.sh --create --zookeeper  xx.xx.xx.64:2181,xx.xx.xx.55:2181,xx.xx.xx.38:2181  --replication-factor 1 --partitions 1 --topic testByZl

sh kafka-console-producer.sh --broker-list xx.xx.xx.64:2181,xx.xx.xx.55:2181,xx.xx.xx.38:2181 --topic testByZl

sh kafka-console-consumer.sh --bootstrap-server xx.xx.xx.64:2181,xx.xx.xx.55:2181,xx.xx.xx.38:2181 --from-beginning --topic testByZl 

bin/kafka-topics.sh --delete --zookeeper xx.xx.xx.64:2181,10.212.168.55:2181,xx.xx.xx.38:2181 --topic testByZl

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.184:9092,127.0.0.185:9092,127.0.0.186:9092 --list

 ./kafka-consumer-groups.sh --bootstrap-server 127.0.0.184:9092,127.0.0.185:9092,127.0.0.186:9092 --delete --group console-consumer-69420