有关kafka的一些命令
-
kafka查看当前消费组消费到哪个offset
cd /opt/kafka/bin #即进入到kafka的bin目录下 bash-5.1# ./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group kafka_test_group_one[分组名称] -
kafka创建topic
./kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --replication-factor 1 --topic ftpCopy[topic名称] -
kafka查看当前所有topic
./kafka-topics.sh --zookeeper 127.0.0.1:9092 --list -
kafka查看所有消费组
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list -
kafka删除某个消费组
./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9091,127.0.0.2:9091,127.0.0.3:9091 --delete --group bbbb[分组名称] -
查询kafka当前最大的offset
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 --topic Notify --time -1 -
手动重置offset
./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:19092,127.0.0.1:19092,127.0.0.1:19092 --group ftpCopy --topic Notify --reset-offsets --to-offset 2347343 --execute -
指定分区 手动重置offset
/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:19092,127.0.0.1:19092,127.0.0.1:19092 --topic Notify --partition 0, --offset 2347343
搬砖完毕，祝你快乐！
标签：0.1,127.0,--,kafka,topic,命令,sh,一些 From： https://www.cnblogs.com/deanCopy/p/16638373.html