Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
从Spring Boot 2.2.2升级到2.3.0后，Kafka消费者指标消失了。
问题：我们将Spring Boot版本从2.2.2升级到2.3.0，在2.2.2的Prometheus端点中看到的所有kafka_consumer_*指标在2.3.0中都不可见。例如，...
减少Spring Cloud Kafka Streams应用中的锅炉模板
在我的Spring Cloud Kafka Streams应用中，我想加入一个KTable 到一个KT表 . 我的应用程序的输入已经使用MessagePack编码，所以我已经为Serdes定义了 ...
Spring Cloud Data Flow自定义Scala处理器无法从启动应用程序发送接收数据（SCDF 2.5.1 & Spring Boot 2.2.6）。
我一直在努力为Spring Cloud Data Flow在Scala中创建一个简单的自定义处理器，并在向启动应用程序发送接收数据时遇到了问题。我一直在...
如何在Spring云Dataflow中使用httpclient处理器？
我正在尝试使用spring cloud dataflow。我的具体使用案例是将GET请求的响应转储到一个日志中。我试图使用httpclient处理器来完成这个任务。但我不明白为什么它......
当消息不能被RabbitMQ路由时，Publisher确认会给出ACK。
我正在做一个小项目来检查RabbitMQ的Publisher Confirms与Spring Cloud Stream 3.0.1的工作情况。我有一个特殊的情况，当一个消息被发送到RabbitMQ的交换，但这......
使用Function接口创建的Spring云流应用程序无法在Spring云数据流中进行数据通信。
我使用Spring云函数方法传输Flux创建了3个简单的Spring云流应用(SourceProcessorSink)。Source-app。@SpringBootApplication public class SourceApplication { ...
Spring Cloud Hoxton.SR5与最新版本的Spring Cloud Schema Registry（2.2.1.RELEASE）不兼容。
我们的微服务实现目前在Spring Cloud Hoxton.SR4上，我们已经能够成功处理Spring Cloud Stream Kinesis请求（发送Avro消息），同时使用Spring ...
我想对异常使用DLQ，这是application.yml主题已成功创建，但是我在DLQ主题中未收到异常消息spring：cloud：stream：default：...
如何向Spring Cloud Dataflow应用程序添加属性
我是Spring Cloud数据流的新手。我正在编写一个“源”应用程序，但无法弄清楚如何向该应用程序添加属性。我在文档中找不到任何帮助。我遵循了...
是Kafka的新手，并且对多个教程感到非常困惑。设置任何kafka avro是否都需要架构注册表？如何使用spring boot-Kafka项目进行设置。
如何在Spring Cloud Kafka Streams应用程序中执行flatTransform？
我正在尝试在Spring Cloud Kafka Streams应用程序中执行flatTransform。但我不确定将KafkaStreamsStateStore批注确切放置在何处。目前，我收到错误消息：Invalid ...
如何测试Spring Cloud Stream Listener
我有一个使用以下方法调用服务的控制器：东西send（SomeMessage message）{binding.sendSomeMessage（）。send（MessageBuilder.withPayload（message）.build（））; } @StreamListener（...
我正在使用带有Kafka活页夹的Spring Cloud Stream的DLQ功能。当消息处理失败时，该消息将按预期发送到DLQ，但是，我希望能够将消息修改为...
了解Spring Cloud Stream Kafka和Spring重试
我有一个使用Kafka活页夹的Spring Cloud Stream项目，我试图理解并最终定制Cloud Stream使用的RetryTemplate。我没有找到很多有关如何...
Spring Cloud Stream Kafka Streams：下游消息数与发送给该主题的消息总数不匹配
我有一个基于Spring Boot的Spring Cloud Stream Kafka Streams Binder应用程序。它定义了一个拓扑，其中包含以下内容：绿色的数字表示通过...
如何处理Spring cloud流kafka流活页夹中的序列化错误？
我正在使用Spring Cloud Stream Kafka Streams绑定器编写Kafka Streams应用程序。使用者将消息发布到输出主题时，可能会出现诸如序列化错误或...
我有兴趣使用Spring Cloud Stream在我们项目中的某些生产者中使用发布者确认。我曾尝试做一个小的PoC，但是它不起作用。据我所见...
我已阅读到，如果某个使用者接受了一条消息，但未确认在给定的时间范围内已成功处理该消息，那么将向另一个使用者提供相同的消息以保证...
如果在处理步骤期间发生故障，如何使Spring云流Kafka流绑定程序重试处理消息？
我正在使用Spring Cloud Stream开发Kafka Streams。在消息处理应用程序中，可能会产生错误。因此，不应提交和重试该消息...
我目前正在试验一种用例，我们必须先将多个输入消息聚合到一个用例中，然后再将其写入文件系统。为此，我正在尝试使用聚合器模块...