Docker化SCDF的流应用程序

我已经能够在Kubernetes集群中设置弹簧云数据流1.2.0.RELEASE，导入入门应用程序并运行诸如“http | log”之类的简单流程。但是，当我尝试在像“http | myApp | log”这样的流中运行我自己的Dockerized流应用程序时，似乎无法使其工作......部署很好，流的Kafka主题按预期创建，没有错误消息来自任何豆荚，但myApp处理器似乎没有意识到Kafka主题，因此从不接收来自http源的数据。Docker化SCDF的流应用程序

我的问题是：是否有什么特别的关于码头化SCDF流媒体应用程序？数据流服务器如何配置K8s窗格以将其指向正确的Kafka主题？我去了https://github.com/spring-cloud-stream-app-starters，似乎无法找到任何Dockerfile示例，所以我不知道它是如何完成入门应用程序的。

我的流应用程序非常简单;代码是这样的：

@SpringBootApplication 
@EnableBinding(Processor.class) 
public class MyAppProcessor 
{ 
    ... 

    @StreamListener(Processor.INPUT) 
    @SendTo(Processor.OUTPUT) 
    List<MyPOJO> doProcessing(List<Double> doubles) { 
     .... 
    } 
}

我也用@ServiceActivator但似乎并没有有所作为。

来源

2017-08-10 E. Yuan

您是否使用开箱即用的http和log应用程序来运行http | log流程？我假设你已经使用指定的012.指定的bit.ly链接导入应用程序（您也可以单独注册应用程序）。您是如何dockerize并将图像提供给SCDF服务器的？该映像需要作为Docker资源提供，然后进行注册。

来源

2017-08-10 22:19:18 sobychacko

我不确定你用于处理器的依赖关系。我刚创建了一个简单的变压器处理器，并写了一些关于我所做的事情的笔记。看看是否有助于让你的榜样。我的笔记在这里：https://gist.github.com/trisberg/39eb9c6346cd3cd7d7c0616e152e141f#file-uppercase-notes-adoc

数据流服务器应该设置流应用程序在部署时需要连接到Kafka的属性。

我们真的应该创建一些更多的示例并记录如何构建Docker。我们使用io.fabric8:docker-maven-plugin来生成开箱即用的应用程序，但在我的示例中，我只是使用了一个简单的Dockerfile。

来源

2017-08-12 19:33:48

Docker化SCDF的流应用程序

回答

相关问题