spring-cloud-stream

首页 > TAG信息列表 > spring-cloud-stream

每个春季云任务触发器是否需要一个JVM进程？

今天,我们有许多批处理作业,这些批处理作业是通过cron表达式在单个应用程序中安排的.我们想更多地隔离这些工作,因此将它们转移到春季云任务. 但是阅读文档[1]得出的结论是,我必须使用TriggerTask(源),后者又将TaskLaunchRequest发送到Tasklauncher(接收器)以最终启动新过程. 这意

java – Spring启动测试失败说,由于缺少ServletWebServerFactory bean,无法启动ServletWebServerApplicationContext

测试类： – @RunWith(SpringRunner.class) @SpringBootTest(classes = { WebsocketSourceConfiguration.class, WebSocketSourceIntegrationTests.class }, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, properties = { "websock

Spring netflix eureka,zuul vs Spring云数据流

我是微服务世界的新手.想知道何时使用Spring eureka,zuul vs spring数据流. 我正在构建一个服务,它反过来将使用多个粒度服务(也就是微服务),聚合所有数据并将聚合数据返回给消费者.所有服务都将在公司基础架构内的本地Intranet中运行.此外,我想负载平衡个别微服务. 微服务部署的技

如何使用Object有效负载而不是MessageCollector中的字符串接收GenericMessage

我尝试使用MessageCollector测试通过spring-cloud-stream发送和接收消息. 当我使用本机java序列化的流云时,一切正常,但当我将序列化更改为json时,MessageCollector返回GenericMessage与字符串有效负载而不是SomeObject有效负载. 配置是 cloud.stream.default.contentType=appli

Spring Cloud Stream RabbitMQ

我试图理解为什么我要将Rabbit云流与RabbitMQ一起使用.我已经看过RabbitMQ Spring教程4(https://www.rabbitmq.com/tutorials/tutorial-four-spring-amqp.html),这基本上就是我想要做的.它创建了一个直接交换,连接了2个队列,根据路由密钥,消息被路由到Q1或Q2. 如果您查看教程,创建

如何从spring cloud stream app启动源生成的kafka消息中删除内容类型标头

对于twitter源,如果我们使用除@StreamListener(Sink)之外的自定义kafka使用者,它将为每个kafka消息创建一个30位的头. @StreamListener将消息正确地发送到带注释的方法(无标题).问题是每个源头的大小都有所不同.那么我怎么能动态地理解消息的头大小,因为我使用的是自定义kafka消费

java – 默认情况下如何使用Kafka Spring Cloud Stream并使用汇合API生成的Kafka消息？

我正在构建一个微服务组件,它将默认使用由其他(SCS)组件生成的Spring Cloud Stream(SCS)Kafka消息. 但我还要求使用来自使用汇合API的其他组件的Kafka消息. 我有一个示例存储库,显示我正在尝试做的事情. https://github.com/donalthurley/KafkaConsumeScsAndConfluent 这是下面的应

春天云流与反应流

我的目标是使用Spring云流和Kafka创建一个应用程序,并发现“被动”世界. 我有一些有用的东西.这是我消费者的一部分.在我的pom中,我宣布： <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-stream-ka

java – Spring云流 – 在应用程序初始化后发送消息

我试图使用“spring cloud stream”向rabbitmq发送一条简单的消息.基本上代码看起来像这样： @EnableBinding(Source.class) @SpringBootApplication public class SourceApplication { public static void main(String[] args) { SpringApplication.run(SourceApplica