ubuntu 安装kafka 基本测试

1、kafka官网下载安装包 
https://kafka.apache.org/downloads

这里我选择 kafka_2.11-2.2.0.tgz
2、解压

tar vxf kafka_2.11-2.2.0.tgz

3、启动zookeeper（kafka自带）
在解压出来kafka_2.11-2.2.0目录下的bin打开终端，输入命令：

./zookeeper-server-start.sh ../config/zookeeper.properties

没安装jdk1.8以上会报错

安装jdk1.8 后（可参照：https://blog.csdn.net/yjt1325/article/details/103466844）， 正常启动zookeeper：

4、启动kafka

在解压出来kafka_2.11-2.2.0目录下的bin另开终端，输入命令：

./kafka-server-start.sh ../config/server.properties

5、Kafka生产数据

在解压出来kafka_2.11-2.2.0目录下的bin另开终端，输入命令：

./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test

kafka写入测试数据：1 2 3 ....

6、消费Kafka消息

在解压出来kafka_2.11-2.2.0目录下的bin打开终端，输入命令：

./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning

7、删除kafka Topic

在解压出来kafka_2.11-2.2.0目录下的bin打开终端，输入命令：

./kafka-topics.sh --delete --zookeeper localhost:2181 --topic test

8、停掉 Kafka  zookeeper

在解压出来kafka_2.11-2.2.0目录下的bin打开终端，输入命令：

./kafka-server-stop.sh

./zookeeper-server-stop.sh

 

分割线————————————————————————————————————————————————

为了方便 可以将zookeeper 和kafka启动的命令写在一脚本（kafka_start.sh）， zookeeper 和kafka停止的命令写在一个脚本(kafka_stop.sh)

kafka_start.sh 文件：

 

#!/bin/sh
/home/jeremy/Softwares/kafka_2.11-2.2.0/bin/zookeeper-server-start.sh /home/jeremy/Softwares/kafka_2.11-2.2.0/config/zookeeper.properties &
/home/jeremy/Softwares/kafka_2.11-2.2.0/bin/kafka-server-start.sh /home/jeremy/Softwares/kafka_2.11-2.2.0/config/server.properties &

kafka_stop.sh文件

#!/bin/sh
/home/jeremy/Softwares/kafka_2.11-2.2.0/bin/kafka-server-stop.sh
/home/jeremy/Softwares/kafka_2.11-2.2.0/bin/zookeeper-server-stop.sh