Products
GG网络技术分享 2025-11-12 18:06 5
基于您给的文档片段,
在开头之前,请确保您的系统是Zui新鲜状态:

sh
sudo apt update
sudo apt upgrade
Ru果Docker尚未安装,您Neng用以下命令安装:
sh
sudo apt install docker-ce
安装完成后启动Docker服务:
sh
sudo systemctl start docker
由于Kafka依赖于Zookeeper,您需要先安装Zookeeper。Neng通过Docker安装:
sh
docker pull wurstmeister/zookeeper
docker run -d --name zookeeper -p 2181:2181 -e ZOOKEEPER_CLIENT_PORT=2181 wurstmeister/zookeeper
从Docker Hub下载Kafka镜像:
sh
docker pull wurstmeister/kafka
运行Kafka容器, 以下命令中请替换您自己的Zookeeper地址和端口以及Kafka地址和端口:
sh
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://your-kafka-address:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -e TZ=Asia/Shanghai wurstmeister/kafka
根据需要,您兴许需要进一步配置Kafka,包括创建主题等。
Neng用以下命令创建一个名为test的主题:
sh
docker exec kafka /opt/kafka/bin/kafka-topics.sh --create --topic test --partitions 1 --replication-factor 1 --zookeeper localhost:2181
Neng用以下命令创建Kafka生产者和消费者:
sh
docker exec -it kafka /bin/bash/opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
您Neng在生产者中输入消息,然后消费者会kan得出来这些个消息。
确保您Yi经成功安装并运行了Kafka, :
sh
docker exec kafka /opt/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181
这样,您就在Docker上成功安装了Kafka。
Demand feedback