这篇文章主要介绍“kafka docker搭建教程”,在日常操作中,相信很多人在kafka docker搭建教程问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”kafka docker搭建教程”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
docke-compose.yml
docker-compose.yaml
version:
'3'
services:
zookeeper:
image:
wurstmeister/zookeeper
container_name:
zookeeper
# always restart
restart:
always
ports:
-
2181
:
2181
kafka:
image:
wurstmeister/kafka
container_name:
kafka
ports:
-
9092
:
9092
# host ip
environment:
KAFKA_ADVERTISED_HOST_NAME:
宿主机IP
KAFKA_ZOOKEEPER_CONNECT:
zookeeper
:
2181
KAFKA_ADVERTISED_LISTENERS:
PLAINTEXT
:
//宿主机IP
:
9092
## 修改:宿主机IP
KAFKA_ADVERTISED_PORT:
9092
KAFKA_BROKER_ID:
1
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR:
1
depends_on:
-
zookeeper
# always restart
restart:
always
volumes:
-
./docker
.sock:
/var/run/docker.sock
kafka-manager:
image:
sheepkiller/kafka-manager
## 镜像:开源的web管理kafka集群的界面
environment:
ZK_HOSTS:
宿主机IP
## 修改:宿主机IP
ports:
-
"9000:9000"
|
启动:
docker-compose up -d
测试:
登陆:docker exec -it kafka bash
创建topic:
kafka-topics.sh --create --topic test \
--zookeeper zookeeper:2181 --replication-factor 1 \
--partitions 1
查看topic:
kafka-topics.sh --zookeeper zookeeper:2181 \
--describe --topic test
生产消息:
kafka-console-producer.sh --topic=test \
--broker-list kafka:9092
消费消息:
kafka-console-consumer.sh \
--bootstrap-server kafka:9092 \
--from-beginning --topic test
按照上面的测试没有问题的话,就证明搭建成功
到此,关于“kafka docker搭建教程”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注天达云网站,小编会继续努力为大家带来更多实用的文章!