Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
自定义 DefaultErrorHandler 未在多个绑定 kafka 中被调用
我有一个spring cloud kafka绑定消费者服务。主要消费者主题和 dlq 消费者位于不同的经纪人中。因此我需要创建多个绑定。 我面临的问题...
组 ID 未注册的应用程序信息 kafka.consumer
我在使用 Spring Cloud Stream 的 Kafka 消费者服务的日志中多次看到这个特定的日志“App info kafka.consumer for group-id unregistered”。我无法理解...
Spring Cloud 2020.0.0 中的 Spring Cloud 总线/流问题
我们有一个 Spring Boot 微服务，它不仅具有 HTTP 端点，还使用 Spring Cloud Bus 来获取刷新事件（来自 Rabbit），并且还有一个 Spring Cloud Stream Sink 来获取自定义
spring-cloud-stream-binder-kafka-streams 消费者在发生 RuntimeException 时关闭
spring-cloud-stream-binder-kafka-streams 当消费者发生异常时，消费者停止并进入 EMPTY 状态。我想测试重试机制，但它没有按预期工作。 （https://docs.s...
有Spring Cloud Stream的http绑定器吗？
我有一个服务需要建模为流应用程序（该服务目前为相同的用例提供同步和异步 api ）。我正在探索是否可以对实际处理进行建模...
如何动态为流绑定器提供组值，以在使用 Spring Cloud Stream 时实现灵活性。我怎样才能实现这个目标？
Spring Cloud Stream Rabbit Binder 动态组名称
使用Spring Cloud Stream时，我需要动态地将组值赋予绑定器，我该怎么做？
我们可以使用 PostgreSQL 而不是默认的 dynamo 数据库来进行检查点和锁定，以防使用 Binder 方法从 Kinesis 消费数据吗
我有一个 Spring Boot 应用程序，它使用 Amazon Kinesis 来使用数据并将其保存到 PostgreSQL。 由于我已经在我的应用程序中使用一个数据库（PostgreSQL），我想避免使用另一个数据库
我正在为其动态创建云流和消费者，因此无法正确定义消费者，因为有关类型的信息丢失了。 在下面的示例中，使用 @Bean 注释定义的消费者...
Amazon Kinesis Stream 名称未按照提供的 application.yml 文件获取
我有一个使用 Amazon Kinesis 来消费数据的 Spring Boot 应用程序。 它使用了错误的流名称 我需要使用的实际名称是：“test-test.tst.v1” 但它使用：“
Spring Cloud Stream 多个 Kafka 集群配置
在我的项目中，我需要连接到两个不同的Kafka代理。 我的 application.yaml 看起来有点像这样： 春天： 云： 功能： 定义：orderCreatedListener;orderProcessedLi...
我试图弄清楚在使用 Spring Cloud Stream 应用程序构建生产者时是否有办法配置 PublishConfirm 行为。我知道建立生产者有两种方法 -
Spring云流项目，Leyton版本忽略kafka DLQ配置
我用Spring Cloud Streaming做了一些实验，其中kafka是数据源。 需要配置 dlq 而我的配置不支持它。 所以我打开了开源示例，它...
Spring 流项目，Leyton 版本忽略 kafka DLQ
我用Spring Cloud Streaming做了一些实验，其中kafka是数据源。 需要配置 dlq 而我的配置不支持它。 所以我打开了开源示例，它...
Kafka Streams 主题保留问题：动态主题配置和未发布的数据
我在与 Spring Cloud Stream 集成的 Kafka Streams 应用程序方面遇到问题。问题围绕着一个特定的主题，它的大小不断增加并且从不释放数据：
Spring Cloud azure kafka 与多个 eventhub 命名空间绑定
了解如何使用 eventhub kafka 配置 Spring Cloud 以在同一命名空间中发送和接收消息，如下所示 https://github.com/MicrosoftDocs/azure-dev-docs/blob/master/articles/java/spr...
Spring云流批处理生产者抛出`SerializationException`
我正在尝试使用文档中描述的批量生成器。 我创建了以下供应商： @豆 公共供应商>> fetch() { return () -> List.of...
如何处理 org.apache.kafka.common.errors.SslAuthenticationException: SSL 握手失败
我的 Kafka 客户端具有以下配置： 春天： 云： 配置： 启用：假 溪流： 卡夫卡： 活页夹： 经纪人：本地主机：9092 zkNodes：本地主机...
我需要轮询消息并将其发布到 RabbitMQ。设置了100个store，每个store可以轮询5条以上消息并将其发布到RabbitMQ。每分钟进行一次轮询。下面是
调度程序没有频道“unknown.channel.name”的订阅者
我正在尝试使用 spring 绑定来运行发布者和订阅者。 确保目的地（交换）是在rabbit-mq本地创建的。 发布者（app.yml） 春天： 云： 溪流： ...