Spring云数据流中的Kafka源代码

Vir*_*aut 4 spring-xd spring-cloud-stream spring-cloud-dataflow

我正在从Spring XD迁移到Spring Cloud Data Flow.当我在寻找模块列表时,我意识到Spring Cloud Flow中没有列出一些源 - 其中一个是KAFKA源.

我的问题是为什么KAFKA源从Spring云数据流中的标准源列表中删除了?

小智 8

当我在寻找模块列表时,我意识到Spring Cloud Flow中没有列出一些源代码

大多数应用程序都已移植,其余应用程序按递增优先级排序 - 您可以跟踪待办事项中的剩余子集.

我的问题是为什么KAFKA源从Spring云数据流中的标准源列表中删除了?

Kafka并没有被删除,事实上,我们对流式使用案例中的Kafka非常痴迷,因此它直接融入了DSL.更多细节在这里.

例如,

(i)如果您要使用Kafka主题(作为源),您的流定义将是:

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

(ii)如果你要写一个Kafka主题(作为接收器),你的流定义将是:

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

(其中*someAwesomeTopic*是指定目的地,主题名称)