为SCDF对流应用进行Docker化

Question

我已经能够在Kubernetes集群中设置spring cloud dataflow 1.2.0.RELEASE，导入starter应用程序，并运行简单的流程，如"http | log“。但是当我尝试在像"http | myApp | log“这样的流中运行我自己的Dockerized stream应用时，我似乎无法让它工作……部署很好，流的Kafka主题是按照预期创建的，没有来自任何pod的错误消息，但是myApp处理器似乎不知道Kafka主题，因此永远不会从http源接收数据。

我的问题是:为SCDF对接一个流媒体应用有什么特别之处吗？数据流服务器如何配置K8s pod以将其指向正确的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，但似乎没有什么不同。

Answer 1

我不确定您的处理器使用了什么依赖项。

我只是created a simple transformer processor and wrote up some notes on what I did。

看看这是否有助于让您的示例运行起来。

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

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

Answer 2

您是否使用了开箱即用的http和log应用程序来运行http | log流程？我假设您使用bit.ly链接作为指定的here导入了应用程序(您也可以单独注册应用程序)。您是如何停靠映像并将其提供给SCDF服务器的？镜像需要作为Docker资源可用，然后进行注册。