Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
具有多种消息类型的卡夫卡和主题（Avro）：消费者（由于在类路径上缺少类，Spring Cloud Spring失败了）>
主题包含两种类型的消息：PaymentStarted和PaymentCompleted。与消费者有两种分离的微服务。所以：Microservice_1，有consumer1应该抓住PaymentStarted ...
Spring cloud stream kafka聚合使用自动装配bean的新实例
是否有办法在Kafka Streams集合内使用Autowired bean的新实例？ @EnableBinding（Processor.class）公共类MessageReceiver {@StreamListener（target = Processor.INPUT）...
如何在连接AUTHENTICATION_SCHEME为AUTHENTICATION_SCHEME_GSS_KRB的Spring Cloud Stream上初始化Solace Binder？安慰：java：主机：tcp：// ..... msgVpn：myvpn ...
Spring Cloud Stream / Function：不使用Java Function / BiFunction的Kotlin lambdas
我有一个使用Spring Boot编写的Kafka流处理应用程序，使用spring-cloud-function和spring-cloud-stream-binder-kafka-streams。处理几个流的方法是...
如何更改Spring Cloud Stream Kafka活页夹的目标？
[将Spring cloud Stream 2.1.4与Spring Boot 2.1.10结合使用，我正在尝试定位Kafka的本地实例。到目前为止，这是我的projetc配置的摘录：spring.kafka.bootstrap-servers = PLAINTEXT：...
无法实例化[org.springframework.cloud.stream.binding.BindingService]：工厂方法'bindingService'抛出异常
我正在尝试使用Spring Cloud Stream和Apache Kafka作为流绑定器的事件驱动架构。 Spring Boot版本：2.1.9 RELEASE Spring Cloud版本：2.2.1 RELEASE我尝试过...
Spring cloud stream RabbitMQ随机失败，出现队列NOT_FOUND错误
我已经配置RabbitMQ集群，并且在RabbitMQ上使用Spring Cloud Stream进行了这样的配置：import org.springframework.cloud.stream.annotation.Input;导入org.springframework.messaging ....
我正在尝试使用Spring云数据流进行poc，并使该应用程序iis在Pivotal Cloud Foundry中运行。在kubernetes和spring dataflow服务器仪表板中尝试相同的方法不是...
[KafkaStreams与Spring-Kafka的交互式查询
我正在用Spring Kafka编写Spring Boot应用程序。由于我的应用程序专注于Kafka Streams，因此我需要使用交互式查询并查询我的状态存储，我想知道：是否有任何特定方法可以......>
kubernetes上的Spring cloud数据流在部署时出现错误
我正在开发Spring Cloud Dataflow Stream应用程序。我能够使用Cloud Foundry中运行的船长来运行Spring云数据流服务器。现在，我正在尝试与正在运行的船长一起运行...
我必须在kafka消息中设置自定义标头，我的kafka集群本身支持标头（1.x.x）。我当前正在使用springCloudVersion = Finchley.RELEASE。当我设置属性默认值时：...
我已经使用Spring Cloud Streams启动了一个小型微服务。我只有两个流绑定，如下所示：cloud：stream：bindings：channelone：destination：org.queue.app ....
如何在Spring Cloud Stream项目中将传入的标头映射为String而不是byte []？]
我有一个简单的Spring Cloud Stream项目，该项目使用Spring Integration DSL流程并使用Kafka活页夹。一切正常，但是来自Kafka的消息头值以byte []的形式到达。这个...
Spring Kafka Admin Client具有安全性的多个引导服务器Kafka（jass_config）
如何通过具有安全性的微服务（Admin MS）连接到多个引导服务器（DEV，STAGE和PROD）？我想连接到所有kafka服务器并创建/管理主题，然后创建...
Spring Cloud Stream和Kafka：Kafka Producer序列化错误
我是Spring Cloud Stream和Kafka的新手。在有效负载中发送字符串时，我从kafka生产者收到以下错误。任何帮助或见解将不胜感激。我尝试过...
Spring Cloud Stream将值生成为包含JSON而不是仅包含JSON的字符串
[在使用Spring Cloud Stream的流处理应用程序中，我获取一个输入流（以整数为键），并在其上调用selectKey以创建具有相同值但带有...的新主题，] ...
消费者：如果中间件失去了与外部应用程序的连接，则再次发送偏移量
一般来说，我是春季云流和kafka的新手。如果外部应用程序未收到最后一条消息，则阻止使用者使用下一个偏移量的最佳方法是什么。我有一个...
KStream.map中的Null值，导致IllegalArgumentException：有效载荷不能为空
问题描述：我正在创建一个Spring Cloud Kafka流应用程序。我有一个输入主题和一个输出主题，并且我正在尝试对输入应用KStream键值转换操作...
标头名称中带有“。”的标头注释，例如@Header（“ foo.bar”），不映射
我有一个带有签名的简单Spring Integration消息端点：@Transformer字符串handleMessage（@Payload字符串有效负载，@Header（“ nerf”）字符串nerf，@Header（“ foo.bar”）字符串foobar）{//。 ...