有关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
搬砖完毕，祝你快乐！
Original: https://www.cnblogs.com/deanCopy/p/16638373.html
Author: Dean_001
Title: 搬砖_kafka的一些命令
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/714445/
转载文章受原作者版权保护。转载请注明原作者出处！