Kubernetes/Spring云数据流>Spring.Cloud.stream.bindings.output。生产者忽略了目标

Question

我正在尝试根据 http://cloud.spring.io/spring-cloud-dataflow/ 中解释的非常简单的示例运行“Hello，world”Spring Cloud 数据流流。我能够创建一个简单的源代码和接收器，并使用 Kafka 在本地 SCDF 服务器上运行它，因此到目前为止一切都是正确的，并且在 SCDF 指定的主题中生成和使用消息。

现在，我正在尝试根据http://docs.spring.io/spring-cloud-dataflow-server-kubernetes/docs/current-SNAPSHOT/reference/htmlsingle/#_getting_started.中列出的说明将其部署到我的私有云中。使用此部署，我能够毫无问题地部署一个简单的“时间|日志”开箱即用流，但我的示例失败了，因为生产者没有在创建pod时指定的主题中写入（例如，spring.cloud.stream.bindings.output.destination=ntest33.nites-源9），而是在主题“输出”中写入。我对接收器组件也有类似的问题，它在主题“输入”中创建并期望消息。

我使用仪表板创建了流定义：

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 = Source.OUTPUT)
public MessageSource<String> timerMessageSource()
{
    return () -> new GenericMessage<>("Hello " + new SimpleDateFormat().format(new Date()));
}

在日志中我可以清楚地看到

2017-04-07T09:44:34.596842965Z 2017-04-07 09:44:34593 INFO main o.s.i.c.DirectChannel:81-频道应用程序。output'有1个订阅者。

问题是，如何正确覆盖必须生成/使用消息的主题，或者使用什么属性和值使其在k8s上工作？

更新:我在使用RabbitMQ时也有类似的问题

2017-04-07T12:56:40.43505177Z 2017-04-07 12:56:40.435信息7-[主]o.s.integration.channel。DirectChannel:Channel”应用程序。output'有1个订阅者。

Answer 1

能否提供有关如何设置该配置属性的更多详细信息？这个特性非常基本，所以这应该是可行的。如果您正在使用流定义来设置它，请使用流定义更新您的问题。

通道名称保持“输出”，因为这是应用程序内部使用的。

Answer 2

问题在于我的码头工人形象。我仍然不知道细节，但使用https://spring.io/guides/gs/spring-boot-docker/指出的docker文件实例化了docker容器中的2个进程，一个有参数，另一个没有，这是一个正常运行时间，因此正在使用。

解决办法是替换

ENTRYPOINT [ "sh", "-c", "java $JAVA_OPTS -Djava.security.egd=file:/dev/./urandom -jar /app.jar" ]

具有

ENTRYPOINT [ "java", "-jar", "/app.jar" ]

它开始工作。该示例指出第一个入口点以及为什么创建 2 个进程必须有充分的理由，但原因仍然超出了我的理解范围。