spring-xd - Spring Cloud 数据流中的 Kafka 源

Question

我正在从 Spring XD 迁移到 Spring Cloud Data Flow。当我查找模块列表时，我意识到 Spring Cloud Flow 中未列出某些源 - 其中之一是 KAFKA 源。

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

Answer 1

When I am looking for module list I realised that some of the sources are not listed in Spring Cloud Flow

大多数应用程序都已移植，其余应用程序的优先级逐渐增加 - 您可以在 backlog 中跟踪剩余的子集。 .

My question is why KAFKA source is removed from standard sources list in spring cloud data flow ?

Kafka 并没有被删除，事实上，我们在流媒体用例的背景下对 Kafka 抱有很高的看法，以至于它被直接融入到 DSL 中。更多详情here 。

例如，

(i) 如果您必须从 Kafka 主题(作为源)消费，您的流定义将是:

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


(ii) 如果您必须写入 Kafka 主题(作为接收器)，您的流定义将是:

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


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