Docker搭建Kafka

下载Kafka和Zookeeper镜像文件

先运行zk，再运行kafka

创建主题

 在项目代码我们可以进行AOP日志处理，将异常信息 发送到Kafaka 然后 Logstash订阅话题，将数据写入到ES中。

Logstash配置:  通过Logstash去订阅主题，主题要保持一致与代码，与创建的主题。

启动Logstash: ./bin/logstash -f  goods_mylog.conf