最近我们在介绍doris数仓,这里会用到大量的doris,所以我们这里介绍下如何使用docker快速搭建一套kafka环境。
一、首先拉取docker镜像
docker pull wurstmeister/zookeeper docker pull wurstmeister/kafka docker images
可以看到我们已经把zookeeper和kafka的镜像都下载下来了
二、启动zookeeper
docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
三、启动kafka
docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=10.206.0.14:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.206.0.14:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
四、进入到kafka的docker容器里面
docker exec -it kafka bash
4.1、测试创建一个topic
kafka-topics.sh --create --bootstrap-server 10.206.0.14:9092 --replication-factor 1 --partitions 1 --topic test
创建成功
4.2、测试向topic为test的队列发送消息
kafka-console-producer.sh --broker-list 10.206.0.14:9092 --topic test
发送成功
4.3、测试从topic为test的队列进行消费
kafka-console-consumer.sh --bootstrap-server 10.206.0.14:9092 --topic test --from-beginning
消费成功
到此kafka的docker安装就安装完毕,测试也完全正常。
还没有评论,来说两句吧...