Tag: spring cloud dataflow

Kubernetes / Spring云数据streamstream> spring.cloud.stream.bindings.output.destination被生产者忽略

我试图运行一个基于http://cloud.spring.io/spring-cloud-dataflow/上解释的非常简单的例子的“Hello，world”Spring云数据stream。 我能够创build一个简单的源代码和接收器，并使用Kafka在我的本地SCDF服务器上运行它，因此，在此之前，所有内容都是正确的，并且在SCDF指定的主题中生成和使用消息。 现在，我正在尝试根据http://docs.spring.io/spring-cloud-dataflow-server-kubernetes/docs/current-SNAPSHOT/reference/htmlsingle/#中列出的说明将其部署到我的私有云中_getting_started 。 使用这个部署，我可以毫无问题地部署一个简单的“time | log”开箱即用的stream，但是我的示例失败了，因为生产者没有写入创buildpod时指定的主题（例如，spring.cloud.stream.bindings.output.destination = ntest33.nites-source9），但在主题“输出”。 我有一个与接收器组件类似的问题，它在“input”主题中创build并期望消息。 我使用仪表板创build了stream定义： nsource1 | log 容器参数的来源是： –spring.cloud.stream.bindings.output.producer.requiredGroups=ntest34 –spring.cloud.stream.bindings.output.destination=ntest34.nsource1 源组件的代码片段是包xxxx; import java.text.SimpleDateFormat; import java.util.Date; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.stream.annotation.EnableBinding; import org.springframework.cloud.stream.messaging.Source; import org.springframework.context.annotation.Bean; import org.springframework.integration.annotation.InboundChannelAdapter; import org.springframework.integration.core.MessageSource; import org.springframework.messaging.support.GenericMessage; @SpringBootApplication @EnableBinding(Source.class) public class HelloNitesApplication { public static void main(String[] args) { SpringApplication.run(HelloNitesApplication.class, args); } @Bean @InboundChannelAdapter(value […]