vi kafka-server-start.sh #编辑，添加以下代码
#!/bin/sh #启动zookeeper /usr/local/kafka_2.12-2.7.1/bin/zookeeper-server-start.sh /usr/local/kafka_2.12-2.7.1/config/zookeeper.properties & sleep 3 #等3秒后执行 #启动kafka /usr/local/kafka_2.12-2.7.1/bin/kafka-server-start.sh /usr/local/kafka_2.12-2.7.1/config/server.properties & :wq! #保存退出创建关闭脚本kafka
vi kafka-server-stop.sh #编辑，添加以下代码
#!/bin/sh #关闭zookeeper /usr/local/kafka/bin/zookeeper-server-stop.sh /usr/local/kafka/config/zookeeper.properties & sleep 3 #等3秒后执行 #关闭kafka /usr/local/kafka/bin/kafka-server-stop.sh /usr/local/kafka/config/server.properties & :wq! #保存退出设置脚本开机自动执行
vi /etc/rc.d/rc.local #编辑，在最后添加一行
sh /usr/local/kafka/kafkastart.sh & ＃设置开机自动在后台运行脚本 :wq! #保存退出 sh /usr/local/kafka/kafkastart.sh #启动kafka sh /usr/local/kafka/kafkastop.sh #关闭kafka其它命令 创建topic
/usr/local/kafka_2.12-2.7.1/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test查看topic
/usr/local/kafka_2.12-2.7.1/bin/kafka-topics.sh --list --zookeeper localhost:2181 test发送消息
/usr/local/kafka_2.12-2.7.1/bin/kafka-console-producer.sh --bootstrap-server localhost:9091 --topic test
说明：可以在后面发送消息，
### 订阅消息 /usr/local/kafka_2.12-2.7.1/bin/kafka-console-consumer.sh --bootstrap-server localhost:9091 --topic test --from-beginning其他
欢迎有问题及时交流~
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多交流
