春季云数据流中的Kafka源码

我正在从Spring XD迁移到Spring云数据流。当我在查找模块列表时，我意识到一些源未在Spring Cloud Flow中列出 - 其中一个来源是KAFKA。春季云数据流中的Kafka源码

我的问题是为什么KAFKA源从春季云数据流中的标准源列表中删除？

来源

2016-07-24 Viren Balaut

当我寻找模块列表，我意识到有些来源不春云上市流通

大多数应用都移植过来，剩下的都是增量优先级 - 你可以保持追踪backlog中剩余的子集。

我的问题是为什么KAFKA源在春季云数据流中从标准源列表中删除？

卡夫卡没有被删除，事实上，我们在流媒体使用案例的背景下非常重视卡夫卡，因此它直接被烧入DSL。更多详情here。

例如，

（i）如你从卡夫卡主题（作为源）消耗，你流的定义是：

stream create --definition ":someAwesomeTopic > log" --name subscribe_to_broker --deploy

（II）如果您要写卡夫卡主题（作为接收器），则您的数据流定义将为：

stream create --definition "http --server.port=9001 > :someAwesomeTopic" --name publish_to_broker --deploy

（其中* someAwesomeTopic *是指定目的地，主题名称）

来源

2016-07-24 14:21:16

如何做到这一点的任何工作示例？我写了一个使用卡夫卡生产者发送字符串“一个很简单的控制台应用程序testme“并将流连接到一个文件，并且它试图转换邮件失败：oscsbkKafkaMessageChannelBinder：无法转换邮件：746573746D65。这个数字是消息“testme”的ascii表示 – ka2

春季云数据流中的Kafka源码

回答

相关问题