kafka日常操作

kafka查看数据

查看所有topic

./kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --list

查看所有group

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list

查看指定topic的订阅信息

./kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic XXXXX

消费指定group的订阅信息

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group XXXXX --describe

查看从当前当前开始到结束，kafka中指定topic接收到的信息

./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic XXXXX

查看所有kafka中接收到的信息

./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic XXXXX --from-beginning

kafka创建指令

kafka创建topic

./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic XXXXX

kafka启动命令

前台启动

./bin/kafka-server-start.sh ./config/server.properties

后台启动

nohup ./bin/kafka-server-start.sh ./config/server.properties >> ./kafka-server.log 2>&1 &

kafka关闭命令

./bin/kafka-server-stop.sh