kafka集成（一）kafka安装与配置

拼搏现实的明天。 2022-04-24 06:08 300阅读 0赞

一、前序：

1、kafka 需要java环境；

2、kafka 最新版本内置了 zookeeper，所以不需要安装zookeeper；

3、下载kafka最新版本，[点击下载][Link 1]，因为下载的是tgz文件，所以不需要安装，解压到相应的地方就可以了。

4、bin 目录下放的是启动kafka的文件，conf目录下放的是kafka的各种配置文件。

二、安装过程：

1、下载安装包[http://kafka.apache.org/downloads.html][http_kafka.apache.org_downloads.html][。][Link 2]注意要下载二进制版本的。

![20180310183119833][]

2、下载后解压到任意一个目录，我的是D:\\javas\\kafka\\kafka\_2.12-2.2.0。

（1）. 进入Kafka配置目录，D:\\develop\\kafka\\kafka\_2.12-1.0.1  
（2）. 编辑文件“server.properties”  
（3）. 找到并编辑log.dirs=D:\\\\develop\\\\kafka\\\\kafka-log,这里的目录自己修改成自己喜欢的  
（4）. 找到并编辑zookeeper.connect=localhost:2181。表示本地运行  
（5）. Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181。

三、使用：kafka以后在使用时需要先启动（和前面的redis一样，启动服务后才可以使用，服务的cmd窗口不要关闭，关闭就是关闭服务）。启动kafka服务的方法：

1、先启动zk：

cd D:\\javas\\kafka\\kafka\_2.12-2.2.0  
.\\bin\\windows\\zookeeper-server-start.bat .\\config\\zookeeper.properties

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70][]

2、启动server：

cd D:\\javas\\kafka\\kafka\_2.12-2.2.0  
.\\bin\\windows\\kafka-server-start.bat .\\config\\server.properties

三、常用命令：

生产与消息：

消费：
    kafka-console-consumer.bat    --bootstrap-server xxx.x.x.x:9092  --topic test --from-beginning
    
    生产：
    kafka-console-producer.bat --broker-list xxx.x.x.x:9092 --topic test

如：

![2019042816234890.png][]

[Link 1]: https://www.apache.org/dyn/closer.cgi?path=/kafka/1.1.0/kafka_2.11-1.1.0.tgz
[http_kafka.apache.org_downloads.html]: http://kafka.apache.org/downloads.html
[Link 2]: http://kafka.apache.org/downloads.html%E3%80%82%E6%B3%A8%E6%84%8F%E8%A6%81%E4%B8%8B%E8%BD%BD%E4%BA%8C%E8%BF%9B%E5%88%B6%E7%89%88%E6%9C%AC%E7%9A%84
[20180310183119833]: /images/20220218/4b277f1605c34ea28389c4cb9cd18ec3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dfdF95X3k_size_16_color_FFFFFF_t_70]: /images/20220218/dc8bec586c7f4748998572206861c7b6.png
[2019042816234890.png]: /images/20220218/694781cdfb8b4f0e9a7341267ba5ca2e.png