文章目录
- 1、kafka集群搭建
- 1.1、下载镜像文件
- 1.2、创建zookeeper容器并运行
- 1.3、创建3个kafka容器并运行
- 1.3.1、9095端口
- 1.3.2、9096端口
- 1.3.3、9097端口
- 1.4、重启kafka-eagle
- 1.5、查看 efak
- 1.5.1、查看 brokers
- 1.5.2、查看 zookeeper
1、kafka集群搭建
1.1、下载镜像文件
docker pull bitnami/zookeeper
docker pull bitnami/kafka
1.2、创建zookeeper容器并运行
docker run -d --name kafka-zk -p 2181:2181 -e ALLOW_ANONYMOUS_LOGIN=yes bitnami/zookeeper
1.3、创建3个kafka容器并运行
1.3.1、9095端口
docker run -d --name kafka-01 -p 9095:9095 -e KAFKA_BROKER_ID=95 -e KAFKA_ZOOKEEPER_CONNECT=192.168.74.148:2181 -e ALLOW_PLAINTEXT_LISTENER=yes -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.74.148:9095 -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL,EXTERNAL:PLAINTEXT,INTERNAL:PLAINTEXT,SASL_EXTERNAL:SASL_PLAINTEXT,SASL_INTERNAL:SASL_PLAINTEXT,SASL_SSL_EXTERNAL:SASL_SSL,SASL_SSL_INTERNAL:SASL_SSL,SSL_INTERNAL:SSL,SSL_EXTERNAL:SSL -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9095 -e KAFKA_MESSAGE_MAX_BYTES=1000000 bitnami/kafka
1.3.2、9096端口
docker run -d --name kafka-02 -p 9096:9096 -e KAFKA_BROKER_ID=96 -e KAFKA_ZOOKEEPER_CONNECT=192.168.74.148:2181 -e ALLOW_PLAINTEXT_LISTENER=yes -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.74.148:9096 -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL,EXTERNAL:PLAINTEXT,INTERNAL:PLAINTEXT,SASL_EXTERNAL:SASL_PLAINTEXT,SASL_INTERNAL:SASL_PLAINTEXT,SASL_SSL_EXTERNAL:SASL_SSL,SASL_SSL_INTERNAL:SASL_SSL,SSL_INTERNAL:SSL,SSL_EXTERNAL:SSL -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9096 -e KAFKA_MESSAGE_MAX_BYTES=1000000 bitnami/kafka
1.3.3、9097端口
docker run -d --name kafka-03 -p 9097:9097 -e KAFKA_BROKER_ID=97 -e KAFKA_ZOOKEEPER_CONNECT=192.168.74.148:2181 -e ALLOW_PLAINTEXT_LISTENER=yes -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.74.148:9097 -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL,EXTERNAL:PLAINTEXT,INTERNAL:PLAINTEXT,SASL_EXTERNAL:SASL_PLAINTEXT,SASL_INTERNAL:SASL_PLAINTEXT,SASL_SSL_EXTERNAL:SASL_SSL,SASL_SSL_INTERNAL:SASL_SSL,SSL_INTERNAL:SSL,SSL_EXTERNAL:SSL -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9097 -e KAFKA_MESSAGE_MAX_BYTES=1000000 bitnami/kafka
1.4、重启kafka-eagle
[root@localhost ~]
kafka-eagle
1.5、查看 efak
1.5.1、查看 brokers
1.5.2、查看 zookeeper
