maven {代码...} kafka {代码...} kafka-spark {代码...} 输出 {代码...} ui docs JavaKafkaWordCount.java

如何使用Kafka实时的收集与存储这些Log4j产生的日志呢？一种方案是使用其他组件（比如Flume，或者自己开发程序）实时监控这些日志文件，然后发送至Kafka。而另外一种比较便捷的方案是使用Kafka自带的Log4jAppender，在Log4j配置文件中进行相应的配置，即可完成将Log4j产生的日志实时发送至Kafka中。

install {代码...} docs Kafka集群搭建

maven {代码...} 高级api实例 {代码...}

zookeeper 安装 {代码...} 修改zook.cfg里头的dataDir 启动 {代码...} kafka 安装 {代码...} 创建topic {代码...} 启动producer {代码...} 启动consumer {代码...} docs kafka＋zookeeper环境配置（Mac 或者 linux环境）

dockerfile [链接] run {代码...}