首先确保已经安装docker,如果是windows安装docker,可参考
wsl2安装docker
docker run -d --restart=always -e ALLOW_ANONYMOUS_LOGIN=yes --log-driver json-file --log-opt max-size=100m --log-opt max-file=2 --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime bitnami/zookeeper:latest
注意:将替换为你的主机IP即可
docker run -d --log-driver json-file --log-opt max-size=100m --log-opt max-file=2 --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=:2181/kafka -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime bitnami/kafka:latest
进入kafka
docker exec -it kafka /bin/bash
cd /opt/bitnami/kafka/bin
查看kafka版本
kafka-topics.sh --version
创建一个新的主题:
./kafka-topics.sh --create --topic test-kafka --bootstrap-server localhost:9092
在开启一个新的终端,一个作为生产者,一个作为消费者
消费者
./kafka-console-consumer.sh --topic test-kafka --from-beginning --bootstrap-server localhost:9092
生产者
./kafka-console-producer.sh --topic test-kafka --bootstrap-server localhost:9092
在生产者页面输入测试内容:
{"id":1,"name":"arvin"}
在消费者页面查看,可见内容
docker run -d --name kafka-map -p 9001:8080 -v /opt/kafka-map/data:/usr/local/kafka-map/data -e DEFAULT_USERNAME=admin -e DEFAULT_PASSWORD=admin --restart always dushixiang/kafka-map:latest
访问 localhost:9001/ 并添加对应的kafka集群信息
本文发布于:2024-02-02 07:49:06,感谢您对本站的认可!
本文链接:https://www.4u4v.net/it/170683134542383.html
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。
留言与评论(共有 0 条评论) |