Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
使用带有rabbitmq粘合剂的弹簧流。我们希望为队列大小设置一个指标。实现队列大小度量的最佳方法是什么？我已经尝试使用注释@ ...
我正在使用云流消耗消息我正在使用类似@StreamListener（target =“CONSTANT_CHANNEL_NAME”）的内容public void readingData（String input）{System.out.println（“consume ...
是否将spring cloud功能webflux + spring cloud stream与http源集成在一起
我正在尝试将spring cloud stream与spring cloud function webflux集成，因为他们在将来的版本中不赞成使用Spring cloud反应流我试图使用spring cloud函数...
构造函数TaskLaunchRequest（String，List ，null，null）未定义 - Spring Cloud Task
我正在使用Spring Boot开发Spring Cloud的代码。在此示例中，我正在使用Spring Cloud Tasks。我正在使用Spring Boot 1.4.1.RELEASE 然后在代码下面......
我遇到了一些情况，我希望暂停消费者停止通过Spring启动应用程序消费消息，消息不应该从队列中丢失，我正在使用amqp和spring cloud stream。 ...
我正在尝试实现一个弹簧启动aws kinesis使用者能够自动缩放，以便与原始实例共享负载（拆分处理分片）。我一直在......
我一直在使用1.0.0版本的云流kinesis binder（https://github.com/spring-cloud/spring-cloud-stream-binder-aws-kinesis）开发一个项目。我有一个入站通道（kinesis ...
Spring Cloud Aws kinesis Binder负载均衡
我正在尝试为Aws kinesis流消费者实现负载平衡根据文档我试图实现spring：cloud：stream：instanceIndex：1 instanceCount：3 ...
如何使用spring-cloud-stream实现Kafka使用者按需处理事件？
我正在尝试实现一个PollableConsumer，它在某种情况下开始轮询来自Kafka的消息，在这种情况下，当我在SpringBoot应用程序中点击一个端点时。我试过多种方式......
使用消费者/生产者API的Kafka的Spring Cloud Stream恰好一次具有transaction-id-prefix的语义不能按预期工作
我有看到不同行为的场景。像总共3个不同的服务一样，第一个服务将从Solace队列中侦听并将其生成到kafka topic-1（启用事务）...
我有两个应用程序使用Spring Cloud流和rabbitmq绑定器互相抛出消息。我无法订阅全局或专用错误通道。我相信我是......
我正在推送100条消息以1 shrad流式传输。 spring：cloud：stream：bindings：myOutBound：destination：my-stream contentType：application / json我...
什么是spring cloud stream kafka的默认Ack模式？
目前我正在使用SCS和SB2.0。只是想知道什么是默认的ack模式？
Spring Cloud Stream Kafka消费者/生产者API恰好一次语义（事务性）
具有事务启用和动态目标的Spring Cloud Stream Kafka存在问题。我有两个不同的服务第一个服务将从Solace队列中侦听并将其生成到kafka topic-1（...
是否可以使用Kubernetes Spring Cloud Dataflow注册google注册表docker容器？
我们的团队正在使用Kubernetes Spring Cloud Dataflow 2.01版，它似乎需要一个明确的docker：// docker容器的URL：https：//docs.spring.io/spring-cloud-dataflow/docs/2.0.0 .. ..
无法使用云kafka流将autoCommitOffset设置为true
我使用spring-cloud-starter-stream-kafka-1.3.3和Spring-cloud-stream与Spring Boot连接到Kafka，它包含我想要enable.auto的典型Publisher Subscriber用例....
Spring-Cloud-Streams Kafka - 如何阻止消费者
我有一个Spring-Cloud-Streams客户端，它读取了一个由几个分区组成的Kakfa主题。客户端为其读取的每个Kafka消息调用Web服务。如果在...之后网络服务不可用
我正在使用Spring Integration + Spring Cloud Stream来创建以下流：@Bean public IntegrationFlow testEventFlow（）{return IntegrationFlows.from（TestEventSink.INPUT）.transform（...
Spring Integration：使用application / octet-stream内容类型的http转换器问题
我有这个流程：@Bean public IntegrationFlow flow（）{return IntegrationFlows.from（QueueMessageSink.INPUT）.transform（Transformers.fromJson（QueueMessage.class））。
在批处理模式下使用消息时，Spring Aws Kinesis Binder ProvisionedThroughputExceededException
我正在使用批处理模式从kinesis流中提取记录。我们正在使用spring aws kinesis binder。大多数情况下，我们无法从流中提取消息。我们只有一段时间......