文档指出，RabbitMQ绑定器使用者的默认恢复间隔为5000ms。 RabbitMQ绑定器配置属性以spring.cloud.stream.rabbit.bindings.recoveryInterval是一个默认值为5000ms的属性。我希望能够为配置中的所有使用者更改它。我试过s
浏览 30提问于2019-10-04得票数 0
回答已采纳
我有一个要求暂停卡夫卡消费者，并在固定的间隔后，它应该恢复卡夫卡消费者的.Pausing如预期的那样工作，但问题是与消费者的简历。在多绑定器场景下，固定时间间隔后未触发ListenerContainerIdleEvent。如果只为单个活页夹配置相同的代码。event.getConsumer().paused()); };
浏览 0提问于2019-05-02得票数 0
使用spring云流，您可以通过指定“默认”属性来避免每个单独通道的冗余属性。例如，如果有两个通道绑定到同一个目的地/交换，则可以：但是.我也想对RabbitMQ绑定属
浏览 0提问于2018-04-12得票数 1
我已经配置了默认的并发设置，并且我有另一个组需要不同的并发级别，但是第二个组的默认并发级别是1。当前版本是spring-boot 2.0.4，springCloudVersion是Finchley.SR1，我使用的是rabbitMQ。spring.cloud.stream.default.group=foo spring.cloud.st
浏览 41提问于2018-09-05得票数 0
2回答
春云巴士-重命名狂犬病队列？
、、、、
有没有办法告诉spring总线重命名它的rabbitmq队列？启动时，它们似乎只是一些随机值，如下所示：试图让spring总线将其重命名为一个更具人类可读性的可预测队列名例如：或者是一些有知识的东西，知道它在为什么服务提供信息。我尝试在application.yml on for bootRun中添加以下内容：
浏览 3提问于2016-10-18得票数 2
回答已采纳
我有一个与Spring Boot Actuator相关的问题。通过Actuator，我可以动态地改变日志级别。或者它将应用于所有节点？
如果它应用于集群中的所有节点，那么如何将其限制为仅特定节点？
浏览 0提问于2018-05-22得票数 0
我正在将遗留的spring应用程序切换到spring启动。mq-test.topic.aa.mq-test
我对春云流的特性是这样的。spring.c
浏览 0提问于2019-05-30得票数 1
回答已采纳
我正在尝试用RabbitMQ配置一个简单的Spring Cloud Stream应用程序。我使用的代码大多取自。：spring: stream: output:
destination但我的问题是，它不会自动创建队列和绑定。我可以看到Rabbit上的流量
浏览 13提问于2016-09-18得票数 2
回答已采纳
我有一个rabbitmq队列和两个spring cloud spring消费者。我希望每个消费者都能按顺序处理消息。我认为当consumer1发送确认时，consumer2会收到第二条消息，所以我预计message1，message2在每个消费者中都是按顺序处理的。pass ------------------------>
consumer2: message2 messa
浏览 15提问于2017-07-13得票数 1
回答已采纳
我有两个微型服务学生和老师@Input("XYZ")在教师微型服务中，我将exchangeapplication.properties spring.cloud.s
浏览 1提问于2018-04-19得票数 2
回答已采纳
使用下面的配置aplication.yml，用于通过Spring Cloud Stream 3.0.12.RELEASE和Spring Boot 2.5.6的消费者应用程序 spring: web-application-type: none stream: consumeSomething-in在该文件<e
浏览 280提问于2021-11-12得票数 0
2回答
我正在尝试用支持来设置RabbitMQspring: stream: binder1: inherit
浏览 2提问于2019-06-05得票数 0
在我的云流应用程序中，我使用了spring-cloud-starter-stream-processor-tasklaunchrequest-transform初学者应用程序作为任务处理器。-rabbit.queues=cloud-stream-source --rabbit.requeue=true --spring.rabbitmq.host=localhost --spring.rabbitmq</em
浏览 4提问于2016-11-04得票数 0
回答已采纳
1回答
我的问题是如何使用Spring Cloud Stream Kafka管理多实例。让我解释一下，在Spring Cloud Stream微服务上下文(eureka，configserver，kafka)中，我希望拥有相同微服务的两个实例。当我在GIT Repository中更改配置时，configserver (通过webhook)会将一条消息推送到Kafka主题中。如果我在我<em
浏览 44提问于2020-07-17得票数 2
回答已采纳
涉及到组件：Spring server、Spring (RabbitMQ)、Spring client
浏览 1提问于2018-03-27得票数 2
回答已采纳
我想为我的配置服务器编写单元/集成测试，所以我检查了链接。里面有一个用@SpringBootTest注释的类和一个用@BeforeClass注释的函数startConfigServer()。我还可以为配置服务器编写哪些其他单元测试用例和集成测试？我还使用了Spring Cloud Stream Kafka和Spring Cloud Bus，同时启用了Spring Security基本身份验
浏览 7提问于2018-07-09得票数 0
我使用spring-cloud-sleuth将相关id添加到我的日志中，用于http请求、rabbitMQ消息和调度事件。添加依赖项后，应用程序启动时间增加了50%。所有其他配置属性，如spring.sleuth.async.enabled、spring.sleuth.grpc.enabled都有默认值true。如果我想减少我的应用程序启动时间，我需要在我的应用程
浏览 11提问于2020-12-01得票数 0
回答已采纳
这个问题类似于，但不同之处在于，我希望在一个消费者spring引导应用程序中使用多个Sinks，并且我希望通过rabbitmq主题(这在spring云流中是默认的)来完成这个任务。我无法找出正确的配置或某些错误的代码。我有三个水槽/共耗器。consumer1是默认的，每条消息都在那里。**根据Garry的建议更新**
注释:我的制作人应
浏览 2提问于2020-03-27得票数 0
回答已采纳
我们部署了一个Zuul代理(用Spring Cloud/Boot打包)，它从Spring Config Server获取配置。每次我更改路由时，我都会重新启动Zuul应用程序，我想知道是否有更好的方法可以采用(如刷新Zuul配置信息)？:)
谢谢,
浏览 1提问于2016-05-27得票数 3
我已经花了一些时间使用CommitFailedException的Stream应用程序。我知道要解决这个问题，我需要设置max.poll.records和max.poll.interval.ms以满足我对处理批处理所需时间的期望。但是，我不太清楚如何在中为消费者设置它。因此，如果消息由于在外部系统上完成工作后的任何问题而无法发布，我必须将其还原回(某种类型的Kafka发布和其他外部系统上的原子事务)。
浏览 3提问于2019-09-17得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
