Centos7安装kafka

安装JDK

 https://www.cnblogs.com/fengyumeng/p/13875508.html

安装zookeeper

https://zookeeper.apache.org/releases.html

本文用的版本是3.7.0

解压：tar -zxvf apache-zookeeper-3.7.0-bin.tar.gz
移走：mv apache-zookeeper-3.7.0-bin /usr/local/zookeeper

生成配置文件

cp /usr/local/zookeeper/conf/zoo_sample.cfg /usr/local/zookeeper/conf/zoo.cfg

编辑配置文件

vim /usr/local/zookeeper/conf/zoo.cfg

修改数据目录：dataDir=/usr/local/zookeeper/data

这里不配集群版，我在云服务器上搭的，配不起。

创建数据目录

mkdir /usr/local/zookeeper/data

添加环境变量

vim /etc/profile

在最下面增加一行：PATH=$PATH:/usr/local/zookeeper/bin

使配置生效：source /etc/profile

启动
zkServer.sh start

停止
zkServer.sh stop

重启
zkServer.sh restart

状态
zkServer.sh status

安装kafka

下载页面：http://kafka.apache.org/downloads

本文使用的版本是kafka_2.13-2.8.0

解压

tar -zxvf kafka_2.13-2.8.0.tgz

移走

mv kafka_2.13-2.8.0 /usr/local/kafka

修改配置文件

vim /usr/local/kafka/config/server.properties

修改
log.dirs=/usr/local/kafka/logs
advertised.listeners=PLAINTEXT://127.0.0.1:9092

创建日志目录

mkdir /usr/local/kafka/logs

启动

/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties

停止

/usr/local/kafka/bin/kafka-server-stop.sh /usr/local/kafka/config/server.properties

测试通信

cd /usr/local/kafka/bin/

使用生产者生产消息

./kafka-console-producer.sh --broker-list localhost:9092 --topic a

使用消费者消费消息

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic a --from-beginning

查看topic

./kafka-topics.sh --list --zookeeper localhost:2181