centos8启动kafka及kafka相关命令汇总

【0】先自动 zk

进入zk根目录； 启动zk服务器  
 

/opt/module/zookeeper-3.4.10/bin/zkServer.sh start

---

【0.1】zk命令行

• ls 列出节点，如 ls /  
• ls2 列出节点，如 ls2 /  
• create 创建节点 [值]，如 create /sichuan "sc"
• create 创建节点 [值]，如 create /sichuan/cd "best"
• get 获取节点信息，如 get /sichuan/cd  
• set 修改节点数据值， 如 set /sichuan/cd "best city"
• get /node watch 监听节点变化，如 get /sanguo watch
• delete /node 删除节点
• rmr /node 递归删除节点
• stat /node 查看节点状态   

---

【1】启动

后台启动  

kafka-server-start.sh -daemon /opt/module/kafka3.0.0/config/server.properties

同步启动

kafka-server-start.sh  /opt/module/kafka3.0.0/config/server.properties

---

【2】开启生产者+消费者   

1）开启生产者  

kafka-console-producer.sh --bootstrap-server centos201:9092,centos202:9092,centos203:9092 --topic hello0416
kafka-console-producer.sh --broker-list centos201:9092,centos202:9092,centos203:9092 --topic hello0415

2）基于zookeeper开启消费者    

kafka-console-consumer.sh --bootstrap-server centos201:9092,centos202:9092,centos203:9092 --topic hello041

但当我们在开启消费者线程时，加上参数 --from-beginning 时
可以消费或收到201之前写的数据；只不过消息无序了；

kafka-console-consumer.sh --topic first --zookeeper centos201:2181 --from-beginning

3）基于 bootstrap-server 开启消费者 

kafka-console-consumer.sh --topic hello0416 --bootstrap-server centos201:9092

4）rsync 把机器1的文件夹下的文件 同步到  机器2

[root@localhost module]# rsync -azv /opt/module/zookeeper-3.4.10/ root@192.168.163.202:/opt/module/zookeeper-3.4.10/

5）关闭防火墙  

systemctl stop firewalld.service

---

【3】操作命令

1） 查看topic

kafka-topics.sh --bootstrap-server centos201:9092 --list

2）创建topic

kafka-topics.sh --bootstrap-server centos201:9092 --create --topic hello12 --partitions 3 --replication-factor 2

3）删除topic

kafka-topics.sh --bootstrap-server centos201:9092 --delete  --topic first

4）查看topic 描述

kafka-topics.sh --bootstrap-server centos201:9092 --describe --topic hello10

【注意】不要搞错了

centos201:2181 针对 zookeeper集群；
centos201:9092 针对kafka集群；

---

【4】spring整合kafka的知识参考

https://potoyang.gitbook.io/spring-in-action-v5/di-8-zhang-fa-song-yi-bu-xiao-xi/8.3-shi-yong-kafka-fa-song-xiao-xi/8.3.3-bian-xie-kafka-jian-ting-qi
https://www.jianshu.com/c/0c9d83802b0c

---

【5】防火墙

• 查看状态 systemctl status firewalld.service
• 打开防火墙 systemctl start firewalld.service
• 关闭防火墙 systemctl stop firewalld.service
• 开启防火墙 systemctl enable firewalld.service
• 禁用防火墙 systemctl disable firewalld.service