问题标签 [spring-cloud-stream]

我有一个带有Hystrix和Spring Cloud Stream通道的RestController：

在实现中， HystrixCommand向ProductUiController生成了一个getDeclaredMethod以查找回退方法，但@EnableBinding隐藏了反射的类方法，任何解决方法的线索？

是否可以为 Apache Kafka 的 Spring Cloud DataFlow 配置身份验证？我在哪里可以看到示例？

谢谢。

有了一个Mesos-Marathon集群和一个带有Spring Cloud Stream的Spring Boot应用程序，它使用来自Kafka的主题，我们现在想要将 Kafka 与 Mesos 集群集成。为此，我们要安装Kafka Mesos 框架。

现在我们有这样的 application.yml 配置：

一旦我们安装了 Kafka Mesos 框架，

我们如何从 Spring Cloud Stream 连接到 kafka？

或更具体地说

配置会如何？

我正在尝试使用 Spring Cloud Stream 和 Kafka 集成创建一个 Spring Boot 应用程序。我在 Kafka 中创建了一个带有 1 个分区的示例主题，并已从根据此处给出的方向创建的 Spring Boot 应用程序发布到该主题

http://docs.spring.io/spring-cloud-stream/docs/1.0.2.RELEASE/reference/htmlsingle/index.html

和

https://blog.codecentric.de/en/2016/04/event-driven-microservices-spring-cloud-stream/

Spring Boot 应用程序 -

卡夫卡生产者类

除了我想处理异常时，一切都运行良好。

如果 Kafka 主题出现故障，我可以在应用程序的日志文件中看到 ConnectionRefused 异常，但内置的重试逻辑似乎是在不停地重试！

根本没有抛出异常供我处理和做进一步的异常处理。我已经阅读了上面 Spring Cloud Stream 文档中 Kafka 的 Producer 选项和 Binder 选项，我看不到任何自定义选项可以让我一直捕获这个异常。

我是 Spring Boot / Spring Cloud Stream / Spring Integration 的新手（这似乎是云流项目的底层实现）。

你们还有什么知道可以将此异常级联到我的 Spring Cloud Stream 应用程序的吗？

我可以创建同时具有绑定 Sink 和 Source 的 Spring Cloud Stream App 的 Spring Boot 应用程序吗？

我刚开始使用spring cloud dataflow项目。

我尝试使用http://start-scs.cfapps.io推荐的 spring initialr 创建一些自定义组件

我发现快速选择的一些组件正在发生冲突

例如，我生成了一个具有以下两个启动器的

我得到的错误是（使用漂亮的 spring boot 1.4.0 诊断）是

我还发现文件和兔子组件甚至没有被引入，除非我明确导入它们的配置文件。

我是 Spring Cloud Data flow 和 Stream Cloud Streaming Applications 的新手。目前我的项目图如下所示：

我使用 zuul API 网关将来自外部客户端的 POST 请求路由到名为 Composite 的微服务。Composite 使用 REST POST 创建流并部署到 Spring Cloud Data Flow Server。据我所知，微服务 mongodb 和文件作为共存的 JVM 进程运行。如果我的客户端必须知道流的状态，处理数据的状态，复合微服务应该如何与 Spring Cloud Data Flow Server 交互？目前，当我进行 POST 调用以部署流时，我什至没有从 SCDF 服务器获得状态。SCDF 是否公开任何挂钩来查看单个应用程序？另外，如何更改流@runtime 以创建动态网格？

目前我正在使用本地 Spring Cloud Data Flow Server 进行开发。

我有以下代码：

}

它只是从 RabbitMQ 获取 amqp 消息，然后根据“expected_destination”标头将消息发送到目的地。

我已经设置spring.cloud.stream.bindings.output.content-type=application/json;charset=UTF-8了，但我看到消息的内容类型是application/x-java-object;type=xxx.AMQPOutboundMessagebase64 编码的消息正文。

但是当我@Autowired用来获取messageChannel时，似乎一切都很好。

那么，我可以知道在这种情况下如何设置内容类型吗？

我正在尝试用于spring.cloud.stream.kafka.binder.headers传输我根据上一个问题设置的自定义标头。

我在文档中阅读了...

似乎建议设置一个列表（逗号分隔？）将导致自定义标头在 中传输Message<>，但是一旦 kafka 写入完成，标头就会丢失。

我的注释创建标题作为对 MessagingGateway 的调用的一部分：

我观察到在第一个 preSend 调试中正确创建了标头：

但是在下一次 preSend 时，标头丢失了：

我的属性包含：

我创建了一个示例 HttpSource 和 HttpSink。我的 application.properties 看起来像这样

HttpSource

HttpSink

我将这两个应用程序都部署到了 Pivotal Cloud Foundry。HttpSource 有一个端点，它在调用时将消息发送到名为“greetings”的主题交换。然后我将 HttpSink 缩放为有 2 个实例。这创建了两个队列并绑定到“问候”交换。

现在，当我到达端点时，我发现消息已发送到两个队列。我知道这一点是因为我跟踪了日志并发现该消息被打印了两次。

如何使消息仅发送到其中一个队列？

编辑：

我没有在 Pivotal Cloud Foundry 中扩展 HttpSink，而是将 HttpSink 部署为两个不同的应用程序。但在 application.properties 中它们属于同一组。其中一个的instanceIndex=0，另一个instanceIndex=1。

即使是现在，我也得到一个绑定为“#”的队列和两个消费者到该队列。

如何让不同的 HttpSink 实例创建自己的队列，并根据 partitionKey 将来自 HttpSource 的消息路由到其中一个？