Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
spring-cloud-stream 请求-回复消息传递模式
是否有一种应该与 spring cloud stream 一起使用的请求 答复模式 我在 spring cloud stream 上找到的所有文档都是针对 MessageChannel send 即发即弃类型的生产者 并且我熟悉 sprin
springcloudstream
Spring Cloud Stream动态通道
我正在使用 Spring Cloud Stream 想要以编程方式创建和绑定通道 我的用例是 在应用程序启动期间 我收到要订阅的 Kafka 主题的动态列表 如何为每个主题创建一个频道 我最近遇到了类似的场景 下面是我动态创建 Subscr
Spring
springboot
ApacheKafka
springcloudstream
Spring Cloud Stream Kafka - 方法必须是声明性的
我已经使用 Spring Cloud Stream 配置了一个基于 Spring Boot 的应用程序 我正在尝试处理 KStream 但不断收到错误 java lang IllegalArgumentException 方法必须是声明性的
Spring
springboot
springcloudstream
springKafka
手动确认消息:Spring Cloud Stream Kafka
我想要实现的场景是使用来自 Kafka 的消息 处理它 如果某些条件失败我不希望确认该消息 为此 我在 Spring Cloud Stream 参考文档中找到了 自动提交偏移量 处理消息后是否自动提交偏移量 如果设置为 false 则消息标
ApacheKafka
springcloudstream
如何为 RabbitMQ 连接设置自定义名称?
能够通过连接名称识别 RabbitMQ 客户端将非常有用 我正在使用 Spring Cloud Streams 抽象 并且使用默认设置我得到类似的东西 如何在 Spring Boot 客户端中设置自定义 RabbitMQ 连接名称 EDIT
rabbitmq
springcloudstream
Jackson无法反序列化(Spring Cloud Stream Kafka)
我试图从 kafka 读取 json 消息并收到异常 该异常表示 Jackson 无法将 json 反序列化为 POJO json就像 code 500 count 22 from 1528343820000 to 152834388000
Jackson
springcloudstream
为什么spring找不到Spring Cloud Stream创建的@Source bean通道?
我正在尝试使用 Spring Cloud Stream 来发布和使用 Kafka 消息 我一直在研究文档这里关于访问绑定通道 http docs spring io spring cloud stream docs Chelsea SR2
springboot
ApacheKafka
springcloudstream
在运行时更改 spring-cloud-stream 实例索引/计数
在 spring cloud stream 中 有没有一种方法可以在不重新启动应用程序的情况下更改应用程序的实例计数和实例索引 另外 是否有任何推荐的方法来自动填充这些值 在微服务世界中 这似乎非常困难 因为服务一直在启动和停止 在 spr
Spring
springcloudstream
Spring Cloud Stream 应用程序 VS Spring Cloud Task 应用程序
我正在探索 SCDF 来为我的系统编排现有的批处理任务 我注意到 SC Stream App Starters 已经提供了一些 OOTB 即可使用的流应用程序 这适合我的用例 从 FTP 中提取 xml 文件 gt ftp 源 定制改造 将
springcloudstream
springclouddataflow
springcloudtask
创建binder时,Spring Cloud config + 总线对配置服务器调用两次
我使用 spring cloud config 和 spring cloud bus 创建了一个简单的项目 由于某种原因 配置客户端两次调用配置服务器 第一次发生在创建引导程序的上下文时 预期的行为是什么 但第二次发生在创建绑定器的上下文时
Java
springboot
springcloudstream
springcloudconfig
Spring Cloud Stream不创建队列
我正在尝试使用 RabbitMQ 配置一个简单的 Spring Cloud Stream 应用程序 我使用的代码大部分取自spring cloud stream 样本 https github com spring cloud spring
Spring
springcloudstream
使用 RabbitMQ 通过 Spring Cloud Stream 为消费者提供多个绑定路由密钥
我想在 Spring Cloud Stream 中配置一个输入通道 以将其绑定到具有多个路由键的同一交换 目的地 我已经设法使用单个路由键来实现此功能 如下所示 spring cloud stream rabbit bindings inp
Spring
springboot
rabbitmq
springcloudstream
如何指定使用Spring Cloud Stream向RabbitMQ发送消息的超时?
我们在发送消息的过程中遇到了网络问题 这导致所有线程都处于阻塞状态 我们正在使用org springframework cloud spring cloud stream 2 0 1 RELEASE and org springframew
Java
rabbitmq
springintegration
AMQP
springcloudstream
带有断路器的 Kafka Consumer,使用 Resilience4j 重试模式
我需要一些帮助来了解如何使用 Spring boot Kafka Resilence4J 提出解决方案 以实现来自 Kafka Consumer 的微服务调用 假设如果微服务关闭 那么我需要使用断路器模式通知我的 Kafka 消费者停止获取
springboot
ApacheKafka
springcloudstream
resilience4j
Spring Cloud Stream供应商功能模型
我正在尝试使用 Spring Cloud Stream 和新功能支持配置 但我无法理解如何实现与注释配置相同的结果 每次创建用户时 我都需要向布鲁克发送一条消息 通过基于注释的配置 我可以像这样完成它 public UserProducer
springboot
springCloud
springcloudstream
重放上一条成功消息中的 Kafka 主题
使用 Spring Cloud Stream 上通道的标准配置 消息会重试 3 次 然后被跳过 如果以下消息处理成功完成 则提交偏移量 这意味着在短暂的异常情况下消息可能会丢失 是否可以更改此行为 以便通道卡在失败消息上 直到瞬态条件得到修
Spring
ApacheKafka
springcloudstream
Spring Cloud Stream 和 RabbitMQ 健康检查
我有一个使用 Spring Cloud Stream Rabbit 和 Eureka Discovery Client 的简单 Spring Boot 应用程序 该应用程序与 Eureka Server 一起工作正常 并且通过 Rabbit
Kafka Spring Cloud Stream 的多个 @EnableBinding
我正在尝试设置一个侦听 Kafka 的 Spring Boot 应用程序 我正在使用 Kafka Streams Binder 用一个简单的 EnableBinding EnableBinding StreamExample StreamP
springboot
ApacheKafka
apachekafkastreams
springcloudstream
Spring Cloud Stream 多个函数定义
是否有可能使用函数式 spring cloud function 具有多个独立函数 绑定的样式 我发现的所有示例始终只注册一个具有默认绑定的功能 beaninput output 我想注册多个 每个都有自己的绑定 传统上这可以使用sprin
springcloudstream
reactive
springcloudfunction
Spring Cloud Stream Kafka Streams Binder KafkaException:无法启动流:“监听器”不能为空
我是 Kafka Streams 和 Spring Cloud Stream 的新手 但在将集成相关代码移至属性文件中方面阅读过有关它的好文章 以便开发人员可以主要关注事物的业务逻辑方面 这里我有我的简单应用程序类 package com
Spring
springboot
ApacheKafka
apachekafkastreams
springcloudstream
1
2
»