kafka 单机部署

# jdk 1.8 install
# zookeeper
wget https://archive.apache.org/dist/zookeeper/zookeeper-3.6.4/apache-zookeeper-3.6.4-bin.tar.gz
进入到 conf 目录，看到 zoo_sample.cfg 文件，cp 复制生成 zoo.cfg 文件，如下：

![](/media/202309/2023-09-09_022800_3053520.6904809049619776.png)
```
启动zookeeper
./bin/zkServer.sh start
查看zookeeper状态
./bin/zkServer.sh status
```

![](/media/202309/2023-09-09_022816_8324190.041392242240873456.png)
`standalone代表单机启动`
# kafka
wget https://archive.apache.org/dist/kafka/3.3.1/kafka_2.13-3.3.1.tgz
进入到 conf 目录，看到config/server.properties 文件，并做如下修改

![](/media/202309/2023-09-09_022843_2564670.16771720260080913.png)
第二步：启动kafka
```
./bin/kafka-server-start.sh config/server.properties &
```

![](/media/202309/2023-09-09_022908_7100190.9802134854249859.png)
第三步：新建topic并查看状态
```
./bin/kafka-topics.sh --create --topic test2 --bootstrap-server 192.168.100.120:9092 
--partitions 1 --replication-factor 1

./bin/kafka-topics.sh --describe --topic test2 --bootstrap-server 192.168.100.120:9092

```

![](/media/202309/2023-09-09_022953_4190290.6069552255719828.png)
然后zoo.cfg指定的目录就有了topic了

![](/media/202309/2023-09-09_023005_0971860.2312355492121615.png)
第五步：生产消息和消费消息
```
# 生产消息
./bin/kafka-console-producer.sh --bootstrap-server 192.168.100.120:9092 --topic test2
# 消费消息
./bin/kafka-console-consumer.sh --bootstrap-server 192.168.100.120:9092 --topic test2 --from-beginning
```
生产的消息被消费了

![](/media/202309/2023-09-09_023047_5053950.35938491116670346.png)