用于SCDF的流应用程序的Dockerizing
我的流应用程序非常简单；代码如下所示：
@SpringBootApplication
@EnableBinding(Processor.class)
public class MyAppProcessor
{
...
@StreamListener(Processor.INPUT)
@SendTo(Processor.OUTPUT)
List<MyPOJO> doProcessing(List<Double> doubles) {
....
}
}
我还使用了@serviceactivator，但似乎没有什么不同。
共有1个答案
我不确定你对你的处理器使用了什么依赖关系。
我只是创建了一个简单的transformer处理器，并记录了一些关于我所做的事情的笔记。
看看这是否有助于你的例子。
-
在PCF上部署spring云数据流2.1.2上的流（app）。 无法让生成的随机app前缀走开。 流部署期间尝试过的选项： deployer.*.cloudfoundy.enableRandomAppNamePrefix=false 尝试将以下环境变量传递给skipper-server 尝试将以下环境变量传递给数据流服务器: SPRING _ CLOUD _ data flow _ TASK _
-
下图说明数据流如何贯穿整个系统： index.php 作为前端控制器，初始化运行 CodeIgniter 所需要的基本资源。 Router 检查 HTTP 请求，以确定谁来处理请求。 如果缓存(Cache)文件存在，它将绕过通常的系统执行顺序，被直接发送给浏览器。 安全(Security)。应用程序控制器(Application Controller)装载之前，HTTP 请求和任何用户提交的数据将
-
我已经阅读了文档，但我不清楚以下情况: 消费者在scdf之外，处理器和接收器在里面。 所有提供的示例，三个组件都在里面。 从我的角度来看，我认为有两种解决方案： SCDF外部的生产者在SCDF中配置的主题中生成消息 在SCDF之外有另一个绑定器，处理器/接收器连接到SCDF之外的这个绑定器 如果有人能提供任何样本，它将非常有用
-
下图说明了整个系统的数据流程： index.php 文件作为前端控制器，初始化运行 CodeIgniter 所需的基本资源； Router 检查 HTTP 请求，以确定如何处理该请求； 如果存在缓存文件，将直接输出到浏览器，不用走下面正常的系统流程； 在加载应用程序控制器之前，对 HTTP 请求以及任何用户提交的数据进行安全检查； 控制器加载模型、核心类库、辅助函数以及其他所有处理请求所需的资源；
-
我们已经构建了一个Flink应用程序来处理来自动觉流的数据。应用程序的执行流程包含基于注册类型过滤数据、基于事件时间戳分配水印的基本操作，以及应用于5分钟数据窗口的映射、处理和聚合功能，如下所示： 我的水印分配程序的参考代码： 现在，这个应用程序的性能很好（在几秒钟内的延迟方面），早就有了。然而，最近在上游系统post中发生了变化，其中Kinesis流中的数据以突发方式发布到流中（每天仅2-3小时
-
我正在尝试使用 Java DSL 部署流。 这里创建流的代码（流畅的风格） 部署方法 以及为源应用程序创建bean的方法 我首先触发方法，然后。问题是-我想为http源代码应用程序将应用程序版本设置为，但为该应用程序部署的最终pod的映像版本等于默认版本。是否可以使用JavaDSL设置应用程序版本？