大数据快速运算（共享）

在spark_chapter06项目中，打开pom.xml文件，添加Kafka Streams依赖。

创建LogProcessor类，并继承Streams API中的Processor接口，实现单词计数业务逻辑。

单词计数的业务功能开发完成后，Kafka Streams需要编写一个运行主程序的类App，用来测试LogProcessor业务程序。

在hadoop01节点创建testStreams1和testStreams2主题；

分别在hadoop01和hadoop02节点启动生产者服务和消费者服务；

运行App主程序类。在生产者服务节点（hadoop01）中输入测试语句，返回消费者服务节点（hadoop02）中查看执行结果。