docker部署kafka
时间: 2023-09-13 22:02:53 浏览: 53
以下是在Docker上部署Kafka的步骤:
1. 首先,需要在Docker中安装Kafka镜像。可以在终端中运行以下命令从官方Docker Hub中下载Kafka:
```
docker pull wurstmeister/kafka
```
2. 下载Kafka镜像后,可以通过以下命令启动Kafka容器:
```
docker run -d --name kafka -p 9092:9092 -e KAFKA_ADVERTISED_HOST_NAME={your_host_ip} -e KAFKA_ZOOKEEPER_CONNECT={zookeeper_host_ip}:2181 -e KAFKA_CREATE_TOPICS=test:1:1 -e KAFKA_AUTO_CREATE_TOPICS_ENABLE=true wurstmeister/kafka
```
其中,{your_host_ip}是您的主机IP地址,{zookeeper_host_ip}是您的Zookeeper主机IP地址。此命令还将在Kafka容器中创建名为“test”的主题。
3. 接下来,可以使用以下命令进入Kafka容器:
```
docker exec -it kafka /bin/bash
```
4. 在Kafka容器中,可以使用以下命令创建新的主题:
```
./bin/kafka-topics.sh --create --zookeeper {zookeeper_host_ip}:2181 --replication-factor 1 --partitions 1 --topic test_topic
```
5. 可以使用以下命令列出所有主题:
```
./bin/kafka-topics.sh --list --zookeeper {zookeeper_host_ip}:2181
```
6. 现在,可以使用以下命令在Kafka容器中启动生产者:
```
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test_topic
```
7. 同样,在另一个终端窗口中,可以使用以下命令启动消费者:
```
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test_topic --from-beginning
```
现在,Kafka已经在Docker上成功部署,并且可以使用生产者和消费者进行测试。
相关推荐
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![docx](https://img-home.csdnimg.cn/images/20210720083331.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)