如何使用 SCDF 运行 我的 Spring 云流
How to run my Spring cloud stream using SCDF
使用 spring 云数据流 运行 我的 spring 云流应用程序的最简单方法是什么？我的想法是创建自定义 source 使用 kafka binder 和 sink 作为预建启动器，file。我正在创建非常基本的应用程序，类似于 this. I tried creating executable jar and registering it as source using dataflow shell, that didn't work at all. I am already following this document。
最后，我发现在 spring 云数据流中注册自定义流更容易，
我能够按照解释 here 使用 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
它运行良好。
Here 是我的源流代码。
使用 spring 云数据流 运行 我的 spring 云流应用程序的最简单方法是什么？我的想法是创建自定义 source 使用 kafka binder 和 sink 作为预建启动器，file。我正在创建非常基本的应用程序，类似于 this. I tried creating executable jar and registering it as source using dataflow shell, that didn't work at all. I am already following this document。
最后，我发现在 spring 云数据流中注册自定义流更容易，
我能够按照解释 here 使用 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
它运行良好。 Here 是我的源流代码。