kafka单机版安装（使用内置zookeeper）

1、安装包下载

kafka安装包官方下载

2、安装

解压至任意目录（这里以/home/app为例）

在/home/app/kafka_2.12-2.4.0目录创建文件夹 zookeeperData kafkaLog

分别修改/home/app/kafka_2.12-2.4.0/config目录下的server.properties和zookeeper.properties如下图所示


后台启动自带的zookeeper 命令：

#/home/app/kafka_2.12-2.4.0目录下执行
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

通过jps命令查看是否启动，出现QuorumPeerMain就说明zookeeper启动成功了

后台启动kafka

#/home/app/kafka_2.12-2.4.0目录下执行
bin/kafka-server-start.sh -daemon config/server.properties

通过jps命令查看是否启动，出现kafka就说明kafka启动成功了

10.创建一个topic

#这里ip地址不能写localhost或者127.0.0.1
bin/kafka-topics.sh --create --bootstrap-server 192.168.xxx.xxx:9092 --partitions 1 --replication-factor 1 --topic test

可以执行以下命令查看test主题是否创建成功

bin/kafka-topics.sh --list --bootstrap-server 192.168.54.159:9092

发送者发布消息，运行kafka提供的生产者脚本，发送消息，默认情况下，每一行都将 作为一个独立的消息被发送

bin/kafka-console-producer.sh --broker-list 192.168.xxx.xxx:9092 --topic test

可以新开一个窗口作为消费者端，消费者订阅topic消息，执行以下脚本订阅test主题消息

bin/kafka-console-consumer.sh --bootstrap-server  192.168.xxx.xxx:9092 --topic test 	--from-beginning

出现刚才发送的消息就成功 啦！！

开机自启动可见后续