Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
[我试图绕过Kafka Streams，并提出一些我似乎无法自行解决的基本问题。我了解KTable和Kafka State Stores的概念，但是... ...>
带有键的键值，消息类型为“ Spring cloud stream SOURCE
我正在尝试使用Spring Cloud Stream发送带有键，值对的消息。我找不到为此的任何API。 org.springframework.messaging.MessageChannel仅将有效负载作为发送的一部分...
如何使用Spring Cloud Stream Supplier将密钥消息发送到Kafka
我想使用Spring Cloud Stream生成发给Kafka的带键（带有特定键的消息）消息。 @SpringBootApplication公共类SpringCloudStreamKafkaApplication {public static void main（...
使用Spring-cloud-stream-kafka-stream的活页夹问题
我正在尝试使用春季云流kafka流阅读kafka。然后将事件汇总到一个分钟的时间窗口中，然后将其归类到其他主题。然后，我需要从...
Kafka流：PolicyViolationException：主题复制因子必须为3
我目前正在构建一个应用程序，该应用程序可以写入kafka主题，并听取相同的主题以从中生成ktable并将其具体化到商店中。我正在运行的代码基于...
Spring Dataflow流文件接收器-需要写入单独的文件
我一直在使用Spring Cloud Dataflow。我已经编写了一个定制的Cloud Stream Processor应用程序，该应用程序接收特定类型的XML文档，并将其拆分为较小的XML文档。 ...
不要在Spring Cloud Stream的反应式功能中将消息标记为已确认
我正在使用带有Java 13的Horsham SR1版本的spring-cloud-stream。我正在使用Google Pub / Sub作为底层消息系统。我有一个类似这样的反应函数：@Bean public Function＆...
Spring Cloud Stream kafka生产者，生产动态kafka主题
我想使用Spring Cloud Stream框架创建一个kafka端点，它将在/ {topic_name}上添加一个http post api。如何动态更改spring.cloud.stream.bindings。
Spring Cloud Kafka基于标题信息流动态消息转换
我正在尝试使用Spring Cloud Kafka Streams处理包含不同类型消息的Kafka主题消息。例如，我们从主题接收到JSON消息，该消息可以是...
如何在Spring RestController内部产生和使用RabbitMQ消息并将其发送回用户
大家好，大家好。我正在开发一个Spring Boot应用程序。这是我的问题。我有一个带有后映射的Spring RestController，可以接收一些数据。然后，我需要发送...
Spring Cloudstream 3 + RabbitMQ配置到现有队列
我正在学习Cloudstream，无法将cloudstream功能 映射到现有队列中。我只是从Spring Cloud文档创建hello world应用程序，但实际上不是...
SSL的Spring Cloud Stream Binder Solace配置
我们正在使用Spring cloud stream sol粘合剂。当我们连接到solace队列和主题时，我们正在尝试配置SSL证书。以下是我们在Java中使用并正在运行的配置-...
Spring Cloud Stream vs Google Native Library
Google提供了自己的库来访问发布/订阅服务。另一方面，Spring Cloud Stream也提供了相同的功能。一个相对于另一个有什么优势吗？
Spring Cloud Stream（Hoxton）Kafka生产者/消费者未使用EmbeddedKafka进行集成测试
我有一个正常工作的应用程序，它使用Hoxton附带的Producer的最新更新。现在，我正在尝试添加一些集成测试，声称生产者实际上正在产生一条消息...
Spring Cloud Stream-查询主题，而没有显式使用KTable / KStream吗？
我正在Java应用程序中使用Spring Cloud Stream库。我想将Kafka Streams活页夹用于状态存储。该应用程序将消息发布到某个主题，我希望使用Kafka ...
我们创建了默认复制因子为1的kafka主题，要对此进行更新，我们在application.yaml中添加了spring.cloud.stream.kafka.binder.replication-factor属性3：该属性没有反映...
当没有运行kafka代理时，如何出于开发目的而禁用Spring cloud流？
我有多个使用kafka经纪人实施spring cloud流的spring boot应用程序。我想知道是否可以停止或禁用Spring Cloud Stream或kafka代理连接以启动应用程序。...
我一直在尝试进行一些搜索（Google，Slack，Stack），但尚未找到答案。我们有一些使用Spring Cloud Streams编写的应用程序，并且对交换...
[使用Spring cloud Stream Kafka侦听器从kafka主题读取消息，并在将异常发送到配置属性spring.cloud.stream.kafka.bindings.input ....的死信队列的情况下，例外]
Spring Cloud Task Launcher不响应发送给Rabbit的新事件
我正在尝试设置一个非常基本的Spring Cloud Task示例，但是我遇到了一个问题，即Task Launcher无法接收事件（我认为）。使用最基本的示例发送事件：@ ...