Spring 云数据流中的 Kafka 源
Kafka Source in Spring Cloud Data Flow
我正在从 Spring XD 迁移到 Spring Cloud Data Flow。当我寻找模块列表时，我意识到 Spring Cloud Flow 中未列出某些来源 - 其中之一是 KAFKA 来源。
我的问题是为什么 KAFKA 源从 spring 云数据流中的标准源列表中删除？
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" --name publish_to_broker --deploy
(其中 *someAwesomeTopic* 是指定目的地，主题名称)
我正在从 Spring XD 迁移到 Spring Cloud Data Flow。当我寻找模块列表时，我意识到 Spring Cloud Flow 中未列出某些来源 - 其中之一是 KAFKA 来源。
我的问题是为什么 KAFKA 源从 spring 云数据流中的标准源列表中删除？
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" --name publish_to_broker --deploy
(其中 *someAwesomeTopic* 是指定目的地，主题名称)