一、安装
1.1、去官网下载kafka的安装包,然后上传到 Linux。
Apache Kafkahttps://kafka.apache.org/downloads.html注意:kafka需要依赖于java环境。
1.2、加压缩,并放到 /usr/local 目录
## 解压缩
tar -zxvf kafka_2.11-0.9.0.0.tgz
## 移动到/usr/local目录
mv kafka_2.11-0.9.0.0 /usr/local
## 重命名
cd /usr/local/
mv kafka_2.11-0.9.0.0 kafka_2.11
二、启动zookeeper
cd /usr/local/kafka_2.11
## 启动zookeeper服务,使用默认配置
./bin/zookeeper-server-start.sh config/zookeeper.properties
三、启动kafka
cd /usr/local/kafka_2.11
## 另起一个控制台,启动kafka服务,采用默认配置
bin/kafka-server-start.sh config/server.properties &
四、启动生产者 producer
cd /usr/local/kafka_2.11
## 另起一个控制台,启动生产者。指定kafka的端口号为9092,设置主题为test
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
五、启动消费者 consumer
cd /usr/local/kafka_2.11
## 另起一个控制台,启动消费者。指定kafka的端口号为9092,设置主题为test
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --bootstrap-server localhost:9092 --topic test --from-beginning
测试
在生产者控制台发送 Hello World,即可在消费者控制台收到Hello World。
参考:
KafKa有界面管理工具,但需要额外安装。kafka管理界面 kafka-eagle - 简书 (jianshu.com)https://www.jianshu.com/p/db9f37bb7f98
kafka安装和启动 - OrcHomehttps://www.orchome.com/6Apache Kafka 教程_w3cschoolhttps://www.w3cschool.cn/apache_kafka/.html