1.下载压缩包https://www.apache.org/dyn/closer.cgi?path=/kafka/2.8.0/kafka_2.13-2.8.0.tgz
2.由于kafka是Java编辑的需要安装Java环境
更新软件包
sudo apt-get update
安装openjdk-8-jdk
sudo apt-get install openjdk-8-jdk
查看java版本,看看是否安装成功
java -version
3.解压之前下载的压缩包,放到自己建好的路径下
4. 开始进行服务开启
cd kafka_2.13-2.8.0
bin/zookeeper-server-start.sh config/zookeeper.properties 启动服务
bin/kafka-server-start.sh config/server.properties 启动kafka
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 创建topic
bin/kafka-topics.sh --list --zookeeper localhost:2181 通过list命令查看创建的topic
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 发送消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning 接收消息(重新开启一个终端cd当文件夹kafka_2.13-2.8.0下 然后输入这个就好了)