问答 2024-08-06 来自:开发者社区

RocketMQ在 Springboot 中消费消息转换错误,无法处理,怎么养重写转换类?

RocketMQ在 Springboot 中消费消息转换错误,无法处理,怎么养重写转换类?

文章 2024-06-30 来自:开发者社区

消息队列 MQ产品使用合集之topic相同,但是tag不同,这个类不能放入map中,该如何处理

问题一:MQTT消息桥接RocketMQ5.0吗? MQTT消息桥接RocketMQ5.0吗? 参考答案: 转RocketMQ5.0也保证不了顺序 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/606334 问题二:MQTT5.0...

问答 2024-03-20 来自:开发者社区

RocketMQ topic相同,但是tag不同,这个类不能放入map中,怎么处理?

RocketMQ ons包中subscription中hashcode是根据topic相同就判断为同一个对象,现在写了两个监听,topic相同,但是tag不同,这个类不能放入map中,改怎么处理?最新版jar也是这样的,不打算修复一下吗?

文章 2024-01-02 来自:开发者社区

RocketMQ-初体验RocketMQ(11)-过滤消息_自定义Java类筛选消息

概述RocketMQ-初体验RocketMQ(10)-过滤消息_SQL92表达式筛选消息 通过SQL92的方式,消费者可以过滤到自己想要的消息,其实RocketMQ还提供了一个更为抢到的功能,支持自定义Java类…直接来看下如何使用的吧集群信息RocketMQ : V4.3.2集群模式: 互为主备节点信息: 192.168.18.130 192.168.18.131 双机互为主备broker-m....

RocketMQ-初体验RocketMQ(11)-过滤消息_自定义Java类筛选消息
问答 2023-11-20 来自:开发者社区

在消息队列 MQ中,请问下 各位大佬,大家在创建 consumer的时候,有遇到这类问题吗

请问下 各位大佬,大家在创建 consumer的时候,有遇到Expected the service PushConsumerImpl-1 [FAILED] to be RUNNING, but the service has FAILED。DEADLINE_EXCEEDED: deadline exceeded after 2.981878875s. [buffered_nanos=29855....

问答 2023-09-06 来自:开发者社区

Flink CDC发到 mq 然后在到 mongo 之类的情况 你们是怎么处理唯一建的?

Flink CDC发到 mq 然后在到 mongo 之类的情况 你们是怎么处理唯一建的?我们有一个场景 monog -> mq -> mongo有一个唯一键的索引删除的时候 按_id 进行删除 这个时候 如果有相同的唯一建的数据插入mq消息收到后 不是一个_id的数据会并行处理 会有问题

问答 2023-08-07 来自:开发者社区

请问在RocketMQ中rocketmq升级有没有最佳实践之类的文档说明呢,我现在从4.4升到4.9

请问在RocketMQ中rocketmq升级有没有最佳实践之类的文档说明呢,我现在从4.4升到4.9.7,broker无法启动,删除了consumequeue目录后可以启动,请问这个是版本不兼容导致的么,删除consumequeue目录会有什么问题么?

问答 2023-07-23 来自:开发者社区

RocketMQ广播类的消息会一直堆积?可以设置自动删除吗?怎么设置?什么版本支持?

RocketMQ广播类的消息会一直堆积?可以设置自动删除吗?怎么设置?什么版本支持?

问答 2023-07-03 来自:开发者社区

大佬,您知道Apache RocketMQ中怎么修改broker端打印log的实现类由logbac?

大佬,您知道Apache RocketMQ中怎么修改broker端打印log的实现类由logback改为log4j2么?

问答 2023-06-06 来自:开发者社区

请教一下,rocketmq-common:5.1.1版本里的protocol被移走后,类的引用报错?

请教一下,rocketmq-common:5.1.1版本里的protocol被移走后,rocketmq-spring-boot-starter包里的DefaultRocketMQListenerContainer类的引用报错怎么解决?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。