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

docker {代码...} maven {代码...} 版本 {代码...} 主要需要引入jackson的scala版本，否则报错如下： {代码...} streaming {代码...} run 启动netcat {代码...} 运行，然后输入空格间隔的字符串，然后打开spark-ui[链接] docs sequenceiq/docker-spark JavaKafkaWordCount