kafka环境搭建:

    一、安装配置java-jdk

   (2)安装目录如下:

    (3)环境变量配置:

    

    

    二、下载kafka

    (1)下载kafka2.10-0.9.0.1版本,自带了zookeeper jar包,不用再次下载zookeeper。kafka代理无状态,zookeeper维持集群状态。下载地址:http://mirror.bit.edu.cn/apache/kafka/2.2.0/kafka-2.2.0-src.tgz

    (2)安装目录(不要带空格)如下:

    

    (3)修改zookeeper和kafka配置文件:

    (4)按照配置创建这两个目录

    (5)cmd启动zookeeper:  

    (6)再开cmd启动kafka:

    (7)再开cmd创建topic发送消息:

    (8)再开cmd接收消息:

  golang实现Kfaka消息发送:

      创建main.go:

      消费消息效果:

  参考博友: