Kafka的保姆级简易安装启动、关闭注意事项、简单使用

Myth丶恋晨 2024-03-17 16:56 10阅读 0赞

## 一.安装： ##

1.1Windows本机tar包安装

1.下载tar包

地址：[Apache Download Mirrors][]，点击下面的连接先将tar包下载下来![c96a15afb4554f3587c791008422ebd5.png][]

2.解压到任意地址但自己要记得位置

![00a8228c95ce4e0fbc82d82fd945dd53.png][]

3.进入到config文件找到server.properties更改信息

搜索，然后找到下面的地方将下面代码复制进去。server.properties文件可以用于配置监听的host、port、broker等

**注意**：这个zookeeper.connect=localhost:2181和log.dirs=./logs是原先就有的，找到修改即可。默认的ZooKeeper连接服务为localhost:2181

#存储到日志文件夹中
    log.dirs=./logs
    
    #本地的zookeeper
    zookeeper.connect=localhost:2181

![a6422da162ae4150b0805825ceec8d3d.png][]

![671eca75ada746b09d104365cff65c87.png][]

然后把这份文件复制一份到Windows下

![6f393f1c23744ce992cd31dc9505fe10.png][]

4.启动Kafka

如果没有本机原先没有的可以进入到bin目录用自带的zookeeper。

进入D:\\Kafka\\kafka\_2.12-2.4.0目录下打开两个cmd窗口,一个启动zookeeper一个启动kafka，使用命令(先启动zookeeper再启动)。

.\bin\windows\zookeeper-server-start.bat config\zookeeper.properties
    
    .\bin\windows\kafka-server-start.bat .\config\server.properties

![15a82bcaed174583871bdcc04f551d41.png][]

上面的要根据实际情况来更换，有些可能是sh的而不是bat

![9f368c0c79c041398fa6aecf7dddc7a7.png][]

![2c11cf433350468a9c604265f652311a.png][]

![da11b0f9f5024c3797e939685eef1cf9.png][]

当出现下面的信息即启动成功

![c960f35d53a349779d2aa2ee49eab4ed.png][]

如果出现以下情况，则需要到环境变量配置一下

![46705c7dcd654747b85142c8bc23bccf.png][]

进入到C:\\Windows\\System32\\wbem，查看是否有WMIC.exe

![c2a89571f0f54bb29f4a694cbbb77aa2.png][]

然后再Path下添加C:\\Windows\\System32\\wbem即可

![a03b6d189a88419fa602c6f8e5f3098f.png][]

1.2Docker安装

# docker直接拉取kafka和zookeeper的镜像
    docker pull wurstmeister/kafka
    docker pull wurstmeister/zookeeper 
    # 首先需要启动zookeeper，如果不先启动，启动kafka没有地方注册消息
    docker run -it --name zookeeper -p 12181:2181 -d wurstmeister/zookeeper:latest
    # 启动kafka容器，注意需要启动三台,注意端口的映射，都是映射到9092
    # 第一台
    docker run -it --name kafka01 -p 19092:9092 -d -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.233.129:12181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.233.129:19092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka:latest
    # 第二台
    docker run -it --name kafka02 -p 19093:9092 -d -e KAFKA_BROKER_ID=1 -e KAFKA_ZOOKEEPER_CONNECT=192.168.233.129:12181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.233.129:19093 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka:latest
    # 第三台
    docker run -it --name kafka03 -p 19094:9092 -d -e KAFKA_BROKER_ID=2 -e KAFKA_ZOOKEEPER_CONNECT=192.168.233.129:12181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.233.129:19094 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka:latest

## 二.kafka关闭 ##

kafka关闭是切记尽量！！！！不要直接关闭命令行窗口，此为暴力关闭，可能会导致kafka无法对日志文件的解锁，再启动的时候无法启动成功。且就算关闭也要按照先关闭kafka再关闭zookeeper的顺序。  
  
建议：通过在命令行执行kafka-server-stop命令来关闭它。

## 三.简单使用： ##

1.新建topic

进入到bin下的Windows新建一个cmd窗口，输入命令，创建了一个test的topic

kafka-topics.bat --create --bootstrap-server localhost:9092 --topic test --partitions 1 -replication-factor 1

![841de8a9d1244d7b9abe49fd00e93f41.png][]

2.查看topic

kafka-topics.bat --list --bootstrap-server localhost:9092

![2dca06461b5c48ee8e4317acc0d99dbe.png][]

参考文章：

[看完这篇Kafka，你也许就会了Kafka\_心的步伐的博客-CSDN博客][Kafka_Kafka_-CSDN]

[Apache Download Mirrors]: https://www.apache.org/dyn/closer.cgi?path=/kafka/2.4.0/kafka_2.12-2.4.0.tgz
[c96a15afb4554f3587c791008422ebd5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/bc2e4840ccd145adb50b24b596b21514.png
[00a8228c95ce4e0fbc82d82fd945dd53.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/69b75015c5b94039a1ff617d732d09ce.png
[a6422da162ae4150b0805825ceec8d3d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/1168ccc0490b4d34b64f45f606969858.png
[671eca75ada746b09d104365cff65c87.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/500c071c0bc24a77ae914dc49eec5721.png
[6f393f1c23744ce992cd31dc9505fe10.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/964890c451ec4d55824480186c45ff2e.png
[15a82bcaed174583871bdcc04f551d41.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/9b556c5a6ed745eaa5a5ffd67e552965.png
[9f368c0c79c041398fa6aecf7dddc7a7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/818dbb229710480e872d4b87f8071c01.png
[2c11cf433350468a9c604265f652311a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/fa5807125c1e404580e0fa30ff99c0dc.png
[da11b0f9f5024c3797e939685eef1cf9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/2f11b439e1544eb9b0aa7ee1af56babd.png
[c960f35d53a349779d2aa2ee49eab4ed.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/f3c602ae7bd0412baeaef4500c149a48.png
[46705c7dcd654747b85142c8bc23bccf.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/acdb383aa5ec43c28be4ff0eb25dabe7.png
[c2a89571f0f54bb29f4a694cbbb77aa2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/1c5d45b125a64aa1a6fe86c0eec82513.png
[a03b6d189a88419fa602c6f8e5f3098f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/58e9e99b3e48440b951e43bc53ef0310.png
[841de8a9d1244d7b9abe49fd00e93f41.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/95d16ec625d044b6990ad8b9ca21812e.png
[2dca06461b5c48ee8e4317acc0d99dbe.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/5c479e0e026c48aaaa1302b76f05b963.png
[Kafka_Kafka_-CSDN]: https://blog.csdn.net/cao1315020626/article/details/112590786?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522168878095416800184193228%2522%252C%2522scm%2522%253A%252220140713.130102334..%2522%257D&request_id=168878095416800184193228&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~all~top_positive~default-1-112590786-null-null.142%5Ev88%5Econtrol_2,239%5Ev2%5Einsert_chatgpt&utm_term=kafka&spm=1018.2226.3001.4187