kafka命令

1.先启动zookeeper

zookeeper-server-start.sh config/zookeeper.properties(配置文件路径)
1

2.进入kafka的bin目录
3.启动kafka命令

kafka-server-start.sh config\server.properties(配置文件路径)
1

4.创建kafka主题(topics)，一个分区和一个副本因子

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic 主题名称
1

5.获取kafka已创建的主题列表

kafka-topics.sh --list --zookeeper localhost:2181
1

6.启动生产者并发送消息，监听默认的9092端口，可在server.properties文件中配置端口

kafka-console-producer.sh --broker-list localhost:9092 --topic 主题名称
1

7.启动消费者接收消息

kafka-console-consumer.bat --bootstrap-server localhost:9092 -topic 主题名称 --from-beginning
1

8.检查哪个代理正在侦听当前创建的主题

kafka-topics.sh --describe --zookeeper localhost:2181 --topic 主题名称
1

9.修改kafka主题的分区数

kafka-topics.sh —zookeeper localhost:2181 --alter --topic 主题名称 --partitions 分区数
1

10.删除kafka的某个主题

kafka-topics.sh --zookeeper localhost:2181 --delete --topic 主题名称
1