Spring Cloud数据流：自定义应用程序流和预构建应用程序流之间的通信
问题:
我完成了tuto:https://docs.spring.io/spring-cloud-dataflow/docs/current/reference/htmlsingle/#_custom_processor_application
然后注册了一个名为transformer（处理器类型）的自定义应用程序。
picture
创建一个流，并使用自定义应用程序部署它。
-问题1：自定义应用程序流的部署永远不会结束。
picture
-问题2：无法在预构建的应用程序流和自定义应用程序之间传输数据。
这里是transormer应用程序的stdout:
picture
这里是日志（接收器）的stdout:
picture
我试过的东西:
-我也试过，但同样的问题->自定义流云处理器
-我试过很多其他网站的其他tuto..
-我试过不同版本的Kafka:1.1.0、1.0.1
-我读过Spring Cloud Stream文档和Spring Cloud Data Flow文档，但我不知道我所做的有什么问题。
提前感谢您将带来的帮助。
共有1个答案
-
下图说明数据流如何贯穿整个系统： index.php 作为前端控制器，初始化运行 CodeIgniter 所需要的基本资源。 Router 检查 HTTP 请求，以确定谁来处理请求。 如果缓存(Cache)文件存在，它将绕过通常的系统执行顺序，被直接发送给浏览器。 安全(Security)。应用程序控制器(Application Controller)装载之前，HTTP 请求和任何用户提交的数据将
-
下图说明了整个系统的数据流程： index.php 文件作为前端控制器，初始化运行 CodeIgniter 所需的基本资源； Router 检查 HTTP 请求，以确定如何处理该请求； 如果存在缓存文件，将直接输出到浏览器，不用走下面正常的系统流程； 在加载应用程序控制器之前，对 HTTP 请求以及任何用户提交的数据进行安全检查； 控制器加载模型、核心类库、辅助函数以及其他所有处理请求所需的资源；
-
因此，我们的想法是从2015年开始对现有的meteor应用程序进行归档。该应用程序分为两部分（后端和前端）。我已经制作了一个巨大的bash脚本来处理所有旧的依赖项。。。软件依赖项。。。等等。我只需要运行脚本，我们就可以让应用程序运行了。但现在的想法是为该项目创建一个docker形象。我应该如何做到这一点？我应该创建一个空的docker映像并在那里运行脚本吗？。谢谢我是docker的新手。
-
我们已经构建了一个Flink应用程序来处理来自动觉流的数据。应用程序的执行流程包含基于注册类型过滤数据、基于事件时间戳分配水印的基本操作，以及应用于5分钟数据窗口的映射、处理和聚合功能，如下所示： 我的水印分配程序的参考代码： 现在，这个应用程序的性能很好（在几秒钟内的延迟方面），早就有了。然而，最近在上游系统post中发生了变化，其中Kinesis流中的数据以突发方式发布到流中（每天仅2-3小时
-
我能以某种方式截获来自应用程序的绝对所有流量吗？我应该做什么来做到这一点？提前谢谢你）
-
我的流应用程序非常简单；代码如下所示： 我还使用了，但似乎没有什么不同。