**
1.kafka环境搭建
**
（安装前请确保已经安装jdk）
1.下载kafka
kafka下载地址
2.将下载好的文件kafka_2.11-1.1.1.tgz上传到新建目录/usr/kafka下
3.解压文件
通过tar -xvf kafka_2.11-1.1.1.tgz 解压文件
4.修改server.properties
（1）配置zookeeper
进入config文件夹，修改server.properties 文件指定到zookeeper的ip和端口，因为我是本地的zookeeper，使用的是默认的端口2181，所以直接指定的是本地地址和端口号(单机版本的zookeeper环境搭建请参考https://blog.csdn.net/weixin_43634978/article/details/107984249)
（2）修改log目录
到此，单机kafka搭建成功
2.kafka相关命令
开启kafka自带zookeeper:
前台运行：
bin/zookeeper-server-start.sh config/zookeeper.properties
后台运行：
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper-run.log 2>&1 &
开启kafka:
前台运行：
bin/kafka-server-start.sh config/server.properties
后台运行：
nohup bin/kafka-server-start.sh config/server.properties > kafka-run.log 2>&1 &
创建kafka主题：
bin/kafka-topics.sh --create --zookeeper 192.168.xx.xx:2191 --replication-factor 1 --partitions 1 --topic test
显示kafka所有主题：
bin/kafka-topics.sh -list -zookeeper 192.168.xx.xx:2191
创建kafka生产者：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
创建kafka消费者：
bin/kafka-console-consumer.sh --zookeeper 10.45.xx.xx:2191 --topic test --from-beginning
注释：
创建kafka生产者以后，可以另开一个窗口创建kafka消费者，这样在生产者窗口输入字符串，在消费者窗口可及时查看