Linuxkafka常⽤命令
1、启动kafka
kafka命令nohup ./kafka-server-start.sh ../config/server.properties &&>/dev/null 2>&1 &
或者不指定⽇志输出位置和设置
./kafka-server-start.sh ../config/server.properties &
2、查看所有topic
./kafka-topics.sh --zookeeper 172.18.111.106:2181 --list
3、删除topic
./kafka-topics.sh --delete --zookeeper 172.18.111.106:2181 --topic audit_db_audit_data_topic
4、查看某⼀分组消费情况
./kafka-consumer-groups.sh --bootstrap-server 172.18.111.106:9092 --describe --group kafka_result_id
5、所有分组消费情况
./kafka-consumer-groups.sh --bootstrap-server 172.18.111.106:9092 --describe --all-groups
6、消费某⼀topic
./kafka-console-consumer.sh --bootstrap-server 172.18.111.106:9092 --topic task_result_topic --from-beginning 7、启动⽣产客户端
./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic kfcs
8、查看某⼀topic的消费情况
./kafka-topics.sh --bootstrap-server 172.18.111.106:9092  --describe --topic xxxx
9、创建topic
./kafka-topics.sh --zookeeper localhost:2181 --create --topic test --partitions 1 --replication-factor 1

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。