# docker镜像源配置 /etc/docker/daemon.json :

{
"registry-mirrors" : [
"https://docker.registry.cyou",
"https://docker-cf.registry.cyou",
"https://dockercf.jsdelivr.fyi",
"https://docker.jsdelivr.fyi",
"https://dockertest.jsdelivr.fyi",
"https://mirror.aliyuncs.com",
"https://dockerproxy.com",
"https://mirror.baidubce.com",
"https://docker.m.daocloud.io",
"https://docker.nju.edu.cn",
"https://docker.mirrors.sjtug.sjtu.edu.cn",
"https://docker.mirrors.ustc.edu.cn",
"https://mirror.iscas.ac.cn",
"https://docker.rainbond.cc",
"https://do.nark.eu.org",
"https://dc.j8.work",
"https://dockerproxy.com",
"https://gst6rzl9.mirror.aliyuncs.com",
"https://registry.docker-cn.com",
"http://hub-mirror.c.163.com",
"http://mirrors.ustc.edu.cn/",
"https://mirrors.tuna.tsinghua.edu.cn/",
"http://mirrors.sohu.com/"
],
 "insecure-registries" : [
    "registry.docker-cn.com",
    "docker.mirrors.ustc.edu.cn"
    ],
"debug": true,
"experimental": false
}
 

# 拉取镜像

docker pull  apach/kafka:llatest 

#docker run命令:

docker run -d \
--name kafka \
-p 9092:9092 \
-p 9093:9093 \
--restart=always \
-v /usr/local/kafka/data:/tmp/kafka-logs \
-e LANG=C.UTF-8 \
-e CLUSTER_ID=s0001 \
-e KAFKA_NODE_ID=1 \
-e KAFKA_PROCESS_ROLES=broker,controller \
-e KAFKA_CONTROLLER_QUORUM_VOTERS="1@192.168.1.110:9093" \
-e KAFKA_LISTENERS="PLAINTEXT://:9092,CONTROLLER://:9093" \
-e KAFKA_ADVERTISED_LISTENERS="PLAINTEXT://192.168.1.110:9092" \
-e KAFKA_LISTENER_SECURITY_PROTOCOL_MAP="PLAINTEXT:PLAINTEXT,CONTROLLER:PLAINTEXT" \
-e KAFKA_CONTROLLER_LISTENER_NAMES="CONTROLLER" \
-e KAFKA_CONTROLLER_SECURITY_PROTOCOL_MAP="CONTROLLER:PLAINTEXT" \
-e KAFKA_AUTO_CREATE_TOPICS_ENABLE="false" \
 apache/kafka

#简单说明 

CLUSTER_ID 集群名字 单个可以不写 多个全部写一样

KAFKA_NODE_ID 节点ID 

KAFKA_PROCESS_ROLES 节点角色 多节点一般只写一个 合理的 1 主controller 2 从broker , 单机测试 可以既是主又是从

KAFKA_CONTROLLER_QUORUM_VOTERS 定义参与投票的成员 可以多个 1@192.168.1.110:9093 含义是: id为1的节点 地址是 ip:port 

KAFKA_LISTENERS  不写Ip监听0.0.0.0 9092用于 外部kafka客户端/消费端 和kafka服务端通讯 9093用于 kafka内部使用选举及监控等 

KAFKA_ADVERTISED_LISTENERS kafka对外暴露的IP和端口 docker内写宿主机IP

KAFKA_LISTENER_SECURITY_PROTOCOL_MAP

KAFKA_CONTROLLER_SECURITY_PROTOCOL_MAP

KAFKA_CONTROLLER_LISTENER_NAMES

以上三个和新特性数据加密协议有关  这里设置明文传输 

KAFKA_AUTO_CREATE_TOPICS_ENABLE 不自动创建topic主题

 # 查询是否启动成功 :  docker logs -f kafka 

# 出现一下提示属于正常:

# 进入bash  :  docker  exec -it kafka bash  

官方的镜像 kafka安装地址在 /opt/kafka 

# 创建topic 

/opt/kafka/bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

# 生产者 发送消息

/opt/kafka/bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

# 消费者  

 /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --partition 0    

(一定要加上 红色部分 , 因为没加 收不到消息 调试了3小时!!! c!!!)