kafka的常用命令
Posted haogege1204
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kafka的常用命令相关的知识，希望对你有一定的参考价值。
在此目录下运行命令
/opt/kafka_2.12-2.2.0/
启动内置的zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
启动kafka服务
bin/kafka-server-start.sh config/server.properties
创建topic话题
bin/kafka-topics.sh --create --topic news（话题名） --bootstrap-server 192.168.79.137（Linux ip地址）:9092 -partitions（分区） 3 -replication-factor 1
查看所有topic话题
bin/kafka-topics.sh --list --bootstrap-server 192.168.79.137:9092
查看指定话题的详情
bin/kafka-topics.sh --bootstrap-server 192.168.79.137:9092 --describe --topic news
创建生产者
bin/kafka-console-producer.sh --broker-list 192.168.237.129:9092 --topic news
创建消费者
bin/kafka-console-consumer.sh --bootstrap-server 192.168.237.129:9092 --topic news
使用外置的zookeeper，内置和外置只需要开一个即可
以下命令是在此目录下运行
/opt/zookeeper-3.4.14
启动zookeeper
bin/zkServer.sh start
查看zookeeper状态
bin/zkServer.sh status
停止zookeeper
bin/zkServer.sh stop
以上是关于kafka的常用命令的主要内容，如果未能解决你的问题，请参考以下文章