spring-cloud - 如何使用 SCDF 运行我的 Spring 云流

Question

使用 Spring Cloud 数据流运行我的 Spring Cloud Stream 应用程序的最简单方法是什么？我的想法是使用 kafka binder 和sink作为预构建的 starter文件创建自定义源。我正在创建非常基本的应用程序，类似于此。我尝试使用数据流外壳创建可执行 jar 并将其注册为源，但这根本不起作用。我已经在关注这个文件了。

Answer 1

最后，我发现在spring cloud数据流中注册自定义流更容易，

如此处所述，我能够使用 Maven 坐标进行注册。

我的解决方案：

对于看起来像的坐标

 <groupId>com.streamdemo</groupId>
 <artifactId>Streamdemo</artifactId>
 <version>0.0.1-SNAPSHOT</version> 

我使用 maven://com.streamdemo:Streamdemo:0.0.1-SNAPSHOT, 并注册到 SCDF。实际命令如下所示：

dataflow:>app register --name mysource --type source --uri maven://com.streamdemo:Streamdemo:0.0.1-SNAPSHOT

它工作得很好。 这是我的源流代码。