我正在从 Spring XD 迁移到 Spring Cloud Data Flow。当我在寻找模块列表时，我意识到 Spring Cloud Flow 中没有列出一些源 - 其中之一是 KAFKA 源。
我的问题是为什么从春季云数据流中的标准源列表中删除了 KAFKA 源？
问问题
2774 次
1 回答
10
当我在寻找模块列表时，我意识到 Spring Cloud Flow 中没有列出一些源
大多数应用程序被移植，其余的应用程序的优先级递增——您可以跟踪待办事项中的剩余子集。
我的问题是为什么从春季云数据流中的标准源列表中删除了 KAFKA 源？
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* 是命名的目的地，一个主题名称）
于 2016-07-24T14:21:16.550 回答