spring-cloud-stream 相关问题

Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务,并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序(单个应用程序上下文)运行。您只需要连接到总线的物理代理,如果类路径上有相关的总线实现,则这是自动的。


Spring Cloud Stream消息JSON转换无效

我按照上面提到的问题将Spring Cloud Stream消息从/到JSON转换配置和配置流按照描述,但是,我无法使其正常工作。我的设置如下。一世 ...

回答 2 投票 2

使用Kafka向Dlq Spring云流发送消息时出错

的pom.xml org.springframework.cloud 弹簧云流 ...

回答 1 投票 0

Spring cloud config - 共享文件或他的位置

我有两个应用程序:一个spriig启动配置服务器,另一个是spring启动配置客户端客户端必须使用名为certificate.json的文件。我想将此文件存储在...中

回答 5 投票 0

spring cloud stream app starter文件源到Spring Batch Cloud Task

我有一个弹簧批量启动应用程序,它采用平面文件作为输入。我将应用程序转换为云任务并部署在spring本地数据流服务器中。接下来,我创建了一个以File Source开头的流...

回答 1 投票 1

通过在每次重启应用程序时创建新的使用者组来重置主题偏移

我有一个Kafka主题和一个在Spring Cloud应用程序中分配(必须)的消费者组的消费者。作为一项要求,在每次应用程序重启时我都需要开始阅读所有收到的消息......

回答 2 投票 0

Spring cloud - 输入与输出

从这个例子:@SpringBootApplication @EnableBinding(MyProcessor.class)public class MultipleOutputsServiceApplication {public static void main(String [] args){SpringApplication.run(...

回答 1 投票 0

Spring集成Kinesis - 找不到合适的实现

我正在运行这个示例 - Spring Cloud Stream Kinesis Sample by Spring云。我在Windows 7中的用户文件夹下的.aws文件夹中的凭据。启动应用程序时,我得到以下内容...

回答 1 投票 0

在API调用上停止和启动订阅者

我一直试图停止并启动SubscribableChannel的订阅者,但似乎无法获取用于调用unsubscribe函数的MessageHandler。使用默认的自动装配...

回答 2 投票 0

更改RabbitMQ Spring Cloud Stream Starter App的内容类型

RabbitMQ Source应用程序的Spring Cloud Stream Starter应用程序的文档列出了几种可能的内容类型,每种类型的输出有效负载的结果类型都不同。但是,它......

回答 1 投票 1

云代工厂中的应用程序级服务绑定,用于Spring启动应用程序

我需要使用不同微服务的mysql服务实例绑定我的spring启动应用程序(在PCF上运行)。我相信应用程序级服务绑定可以帮助我,但我......

回答 1 投票 0
推荐问题