Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
Springcloud总线自定义消息无法通过rabbitmq发送
使用springcloud总线时，会创建一个自定义消息并通过rabbitmq发送，但在发送消息后，它不会转到rabbitmq。当您尝试呼叫/执行器/总线刷新时，您可以......
我们可以使用Spring Cloud流将消息发布到SOLACE中，而无需在队列/主题上配置使用者吗？
我试图使用Spring Cloud Stream将消息发布到Solace而不配置消费者，我收到此错误“org.springframework.integration.MessageDispatchingException：Dispatcher ...
用于通用消息通道源的Spring Cloud Stream启动器应用程序
有一个“兔子”源应用程序，它监听指定的兔子队列并生成消息，但我找不到一个“消息通道”源，它可以绑定任何消息代理......
为什么spring-cloud-stream在向Solace主题发布消息时不会填充JMSMessageID？
问题摘要在我的项目中，我们尝试使用Spring-Cloud-Stream（SCS）连接到Solace。最终我们计划搬到卡夫卡。所以使用SCS将帮助我们转移到Kafka ......
test stream-rabbitmq发生错误：Dispatcher没有通道订阅者
我编写了一个使用spring-cloud-starter-stream-rabbit的测试类，当我只运行receiver，并从rabbitmq发送消息时，它可以工作;但是当我运行测试发送器类时，它会发生错误：org ....
如何忽略Kafka Streams应用程序中的某些类型的消息，这些消息从同一主题读取和写入不同的事件类型
假设Spring Cloud Stream应用程序根据订单主题创建KStream。它对OrderCreated {“id”：x，“productId”：y，“customerId”：z}事件感兴趣。一旦到达，它就会处理......
我使用spring-cloud-starter stream-kafka连接到kafka，版本2.1.2。当我在k8s集群中启动服务时，前几个可以成功连接。发生以下错误...
Spring Cloud Stream Kafka应用程序无法使用正确的Avro架构生成消息
我有一个带有KStream的应用程序（spring-boot-shipping-service），它获取由外部生产者（spring-boot-order-service）生成的OrderCreatedEvent消息。这个制片人使用以下......
Spring Cloud Stream Kafka Stream与本机Kafka Stream应用程序和生产者之间不兼容的Avro消息
验证这一点的示例应用程序可以在https://github.com/codependent/event-carried-state-transfer/tree/avro kafka-xxx中找到：本机应用程序spring-boot-xxx：Spring Cloud Stream ...
我们如何为Spring Cloud Stream Kafka生产者，消费者和KStreams中的模式配置value.subject.name.strategy？
我想在Spring Cloud Stream Producers，Consumers和KStreams中自定义Avro架构主题的命名策略。这将在Kafka中使用属性key.subject.name ....
如何在属性文件spring boot中设置Acks = all
我想在我的spring cloud stream kafka应用程序中为我的制作人设置acks = all属性。我试过这样的：spring.cloud.stream.kafka.binder.requiredAcks = all和spring.cloud.stream ....
我有一个制作人（使用Kafka）和一个以上的消费者。因此，我在主题中发布消息，然后我的消费者接收并处理消息。我需要在生产者处收到回复......
Spring Cloud Streams的StreamRetryTemplate不在集成测试中重试
我们正在使用Spring Cloud Streams来监听Kafka主题并呼叫休息服务。我们还实现了一个自定义StreamRetryTemplate来指定我们认为可恢复的错误类型以及哪些错误......
带有融合模式注册表的Spring Cloud Stream Kafka无法将Message发送到通道输出
我想使用Confluent Schema Registry和Avro Schema evolution测试Spring Cloud Stream，以便将它与我的应用程序集成。我发现Spring Cloud Stream不支持...
Spring Kafka / Spring Cloud Stream如何保证涉及数据库和Kafka的事务性/原子性？
Spring Kafka，以及Spring Cloud Stream，允许我们创建事务性生产者和处理器。我们可以看到其中一个示例项目中的功能：https：//github.com/spring -...
我正在以批处理模式消费消息。我想从流中每250毫秒提取8条消息。 spring：cloud：stream：kinesis：bindings：input：consumer：...
我正在使用Spring Cloud Finchley.RELEASE与RocksDb和Kafka-Streams进行生产应用。有时Kafka-Streams进入ERROR状态，除了...之外无法访问商店
带有aws-kinesis的Spring Cloud Bus
在Spring Cloud Bus（https://github.com/spring-cloud/spring-cloud-bus）的文档中，有人提到过，总线启动器涵盖了Rabbit和Kafka，因为它们是最常见的两个......
已请求默认活页夹，但“org.springframework.cloud.stream.messaging.DirectWithAttributesChannel”没有可用的活页夹
我试图用Spring Cloud + Kafka Streams + Spring Boot 2创建最简单的hello世界。我意识到我错过了基本的概念。基本上，我理解：1 - 我需要定义一个......
我想在死信队列中自定义异常消息或添加带有自定义异常消息的新标头参数。现在我在死信队列消息@StreamListener（Sink ....）的标题中得到了原始的堆栈跟踪。