golang连接kafka消费进ES操作

上面代码是读kafka消费数据通过sendToES这个函数发送至ES里面sendToES代码如下Index就是索引名称index().type().bodyjson().do()这样的写法是链式执行操作9.写完了基本操作后 再写一个模拟写入数据进kafka的数据 代码如下这个就是生产者往kafka里面写入数据进去消费10.我们启动我们的kafka 注意kafka依赖于zookeeper 先启动ZK然后启动kafka我这里用的是zookeeper-3.4.12网上有下载启动ZKZK已经成功启动11.启动kafka 我这里是kafka_2.11-1.1.0