SpringXD流中的处理器如何从kafka源模块获取数据

【问题标题】：SpringXD How can a processor in a stream to get data from a kafka source moduleSpringXD流中的处理器如何从kafka源模块获取数据
【发布时间】：2015-12-10 22:45:31
【问题描述】：

我定义了以下流：

stream create aStream –definition “kafka –zkconnect=localhost:2181 --topic aTopic | aProcess"

我的问题是我应该如何编码 aProcess 以便它可以从内置的 kafka 源模块接收数据（以字符串形式）并打印数据？非常感谢。

【问题讨论】：

标签： spring stream processor

【解决方案1】：

您无需编写任何代码。您需要做的就是在您的流定义中指定一个接收器模块。

stream create aStream –definition "kafka –zkconnect=localhost:2181 --topic aTopic |日志”--部署

会将其写入 XD 容器的 STDOUT，或者您可以使用文件接收器将其写入文件。您需要编写自定义模块的唯一时间是获取任何开箱即用的源、接收器或处理器未提供的功能，可在以下位置找到 http://docs.spring.io/spring-xd/docs/current/reference/html/

【讨论】：