安装

官网

http://kafka.apache.org/downloads

1.下载

2.解压

功能验证

1.启动 Zookeeper

使用安装包中的脚本启动单节点Zookeeper 实例:

2. 前台启动 Kafka 服务

使用kafka-server-start.sh 启动kafka 服务:

2.1 Kafka 后台启动

 目的是想让服务后台启动,隐约记得&符号代表后台启动,运行命令后服务确实后台启动了,但日志会打印在控制台,而且关掉命令行窗口,服务就会随之停止,这个让我挺困惑的。后来,参考了其他的启动脚本,通过测试和调试最终找到了完全满足要求的命令。

满意的命令:

其中1>/dev/null  2>&1 是将命令产生的输入和错误都输入到空设备,也就是不输出的意思。
/dev/null代表空设备。

3.创建topic

使用kafka-topics.sh 创建单分区单副本的topic test:

查看topic:

4.产生消息

使用kafka-console-producer.sh 发送消息:

5.消费消息

使用kafka-console-consumer.sh 接收消息并在终端打印:

Centos  安装 Kafka 后台启动 教程-新乡seo|网站优化,网站建设_微信公众号:zeropython—昊天博客