Docker安装Kafka（docker-compose）、EFAK监控

$ docker pull wurstmeister/zookeeper$ docker pull wurstmeister/kafka

docker run -d --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper$ docker run -d --restart=always --log-driver json-file --log-opt max-size=100m --log-opt max-file=2  --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper

## docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=172.16.0.13:2181/kafka -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.16.0.13:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime wurstmeister/kafka$ docker run -d --restart=always --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=172.16.0.13:2181/kafka -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.16.0.13:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime wurstmeister/kafka

$ docker exec -it kafka bash

$ cd /opt/kafka_2.12-2.3.0/bin/

$ ./kafka-console-producer.sh --broker-list localhost:9092 --topic sun

> hello world

$ ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sun --from-beginning

version: "2" services:  #服务名，也可自定义  zookeeper:    image: wurstmeister/zookeeper    container_name: zookeeper    ports:      - "2181:2181"  kafka:    image: wurstmeister/kafka    container_name: kafka    expose:      - "9999"    ports:      - "9092:9092"      - "9999:9999"    environment:      KAFKA_ADVERTISED_HOST_NAME: 192.168.233.129      KAFKA_ZOOKEEPER_CONNECT:  zookeeper:2181      JMX_PORT: 9999  #启用远程JMX 监控面板用    volumes:      - /var/run/docker.sock:/var/run/docker.sock

docker-compose config -q  # 检查配置，有问题才有输出，进入docker-compose.yml文件目录执行docker-compose up -d  # 启动所有docker-compose服务并后台运行docker ps  # 查看容器

docker exec -it 容器id或容器name bashcd bin./zkCli.shls /

ls /brokers/idsls /brokers/topics

tar -zxvf kafka-eagle-bin-2.0.7.tar.gztar -zxvf efak-web-2.0.7-bin.tar.gz -C /opt/module/mv efak-web-2.0.7/ efak

# 第一处efak.zk.cluster.alias=cluster1cluster1.zk.list=192.168.233.129:2181

# 第二处####################################### kafka offset storagecluster1.efak.offset.storage=kafka# cluster2.efak.offset.storage=zk

# 第三处####################################### kafka sqlite jdbc driver address####################################### sqlite 和 mysql 都可以####################################### kafka mysql jdbc driver address######################################efak.driver=com.mysql.cj.jdbc.Driverefak.url=jdbc:mysql://192.168.233.129:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNullefak.username=rootefak.password=123456

sudo vim /etc/profile.d/my_env.sh# kafkaEFAKexport KE_HOME=/opt/module/efakexport PATH=$PATH:$KE_HOME/bin

source /etc/profile

# 启动kafka-eaglebin/ke.sh start

#查看进程，启动失败控制台不会报错，只能去看日志 ps -ef|grep efak

ISKAFKASERVER="false"if [[ "$*" =~ "kafka.Kafka" ]]; then    ISKAFKASERVER="true"fi

if [  $JMX_PORT ] && [ -z "$ISKAFKASERVER" ]; then