南沙滩做网站公司,制作网站素材,wordpress录播,衡东网站定制通过Docker拉取镜像的方式进行安装
照例先去DockerHub找一下镜像源#xff0c;看下官方提供的基本操作#xff08;大部分时候官方教程比网上的要清晰一些#xff0c;并且大部分教程可能也是翻译的官方的操作步骤#xff0c;所以直接看官方的就行#xff09;
老实说Kafka…通过Docker拉取镜像的方式进行安装
照例先去DockerHub找一下镜像源看下官方提供的基本操作大部分时候官方教程比网上的要清晰一些并且大部分教程可能也是翻译的官方的操作步骤所以直接看官方的就行
老实说Kafka的参数配置项太多了比较繁琐。
如果是Linux环境下打算直接用官方提供的docker-compose直接读取yml配置文件了
docker-compose.yml
version: 3
services:zookeeper:image: bitnami/zookeeper:latestports:- 2181:2181environment:- ALLOW_ANONYMOUS_LOGINyeskafka:image: bitnami/kafka:latestports:- 9092:9092environment:- KAFKA_BROKER_ID1- KAFKA_CFG_LISTENERSPLAINTEXT://0.0.0.0:9092- KAFKA_CFG_ADVERTISED_LISTENERSPLAINTEXT://192.168.59.149:9092- KAFKA_CFG_ZOOKEEPER_CONNECTzookeeper:2181- ALLOW_PLAINTEXT_LISTENERyesdepends_on:- zookeeper直接运行即可
docker-compose up -d官网同时还提供了Kafka without Zookeeper (KRaft)的配置方式
WIn10可以在Docker容器内部通过挂载配置文件继续用上面的方式但我这里决定用繁琐的方式一步步来
拉取Zookeeper和Kafka镜像
docker pull zookeeper
docker pull bitnami/kafka:3.1在Docker容器内创建网络连通Zookeeper和Kafka
app-tier网络名称 –driver网络类型为bridge
docker network create app-tier --driver bridge启动Zookeeper节点
在Docker run命令里加上--network app-tier让Zookeeper容器启动后连接上创建的网络(并且允许匿名登陆)
docker run -d --name zookeeper-server --network app-tier -e ALLOW_ANONYMOUS_LOGINyes zookeeper启动kafka服务端
同样的方式让Kafka服务端节点也连上这个网络
dockerun -d --name kafka-server --network app-tier -p 9092:9092 -e ALLOW_PLAINTEXT_LISTENERyes -e KAFKA_CFG_ADVERTISED_LISTENERSPLAINTEXT://192.168.59.149:9092 -e KAFKA_CFG_ZOOKEEPER_CONNECTzookeeper-server:2181 bitnami/kafka:3.1
注意:
KAFKA_ADVERTISED_HOST_NAME为当前主机IP或地址重点如果是服务器部署则配服务器IP或域名否则客户端监听消息会报地址错误
kafka 节点启动后会向 zookeeper 注册自己同时告诉 zookeeper 自身的通信地址这个地址就是配置文件中的 advertised.listeners如果没有配置 advertised.listeners就会使用listeners。
启动Kafka客户端
Finally we create a new container instance to launch the Apache Kafka client and connect to the server created in the previous step:
docker run -it --rm --network app-tier -e KAFKA_CFG_ZOOKEEPER_CONNECTzookeeper-server:2181 bitnami/kafka:3.1 kafka-topics.sh --list --bootstrap-server kafka-server:9092Producer and consumer using external client
These clients, from the same host, will use localhost to connect to Apache Kafka.
#生产者创建Topic
kafka-console-producer.sh --bootstrap-server 127.0.0.1:9092 --topic test
#消费者接收消息
kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning最后发送个经典的Hello World做为测试
kafka-server kafka-client 最后推荐一个kafka的图形化管理工具kafka-map
访问地址http://服务器IP:9001/ #端口号看自己喜好修改映射
DEFAULT_USERNAME默认账号admin
DEFAULT_PASSWORD默认密码admin
GitHub地址https://github.com/dushixiang/kafka-map/blob/master/README-zh_CN.md
Gitee地址 https://gitee.com/dushixiang/kafka-map拉取镜像
docker pull dushixiang/kafka-map:latest启动运行
docker run -d --name kafka-map --network app-tier -p 9001:8080 -v /opt/kafka-map/data:/usr/local/kafka-map/data -e DEFAULT_USERNAMEadmin -e DEFAULT_PASSWORDadmin --restart always dushixiang/kafka-map:latest
