rocketmq

6热度

7回答

[apache/rocketmq]%RETRY%队列下面订阅的是所有的tag*导致消息无法正确推送

有AB两个消费者他们的groupname不同，然后订阅了同一个topic，A 订阅 tag1，B订阅tag2 B消费者里面像这个topic下面的tag1发送一个消息。这个重试队列的订阅应该是到A的重试队列下面。然后由A去消费? 消息正常抵达到消费者A，但是由于A异常没有返回success也没用返回重试。导致这条消息最终进入到了B的消费者重试队列里面，也就是Mq的%RETRY%ConsumerB下

10热度

5回答

[apache/rocketmq]rocketmq4.6 事物消息全部回滚 transactionListener设置没有效果

rocketmq4.6 事物消息全部回滚 transactionListener设置没有效果 broken返回来的transactionID的全是null 用console查看RQM_HALF队列消息全部报错org.apache.rocketmq.client.exception.MQClientException: CODE: 17 DESC: No topic route info in na

6热度

9回答

[apache/rocketmq]一条消息多个标签组合，消费端如何过滤是否包含指定字符串标签

一条消息多个标签组合，消费端如何过滤是否包含指定字符串标签；例如：消息体：aaa tag: 1;2;3;4 三个消费组，A消费组只想要tag包含1和3的消息；B消费组只想要tag包含2的消息；C消费组只想要tag包含4的消息; 因为是同一条消息而且消息体可能会比较大，不可能让生产者把同一条消息发送多次来区分；这种情况使用tag过滤应该如何处理？

7热度

5回答

[apache/rocketmq]询问是否支持手动提交事务消息？

类似 jdbcTranscationManager 的接口 commit()、rollback() 等，目前实现事务需要实现 TransactionListener ，然后需要把本地事务代码写入 executeLocalTransaction, rocketMQ 在发送完半消息后会自动调取，但这个设计的侵入性是否太强？假设，消息的发起者需要本地事务的返回值时应该怎么处理？

1热度

5回答

[apache/rocketmq]事务消息能够快速提交吗？

有没有事务消息的官方例子？没有找到事务消息的官方例子，谷歌搜出来的靠前的例子为这个：https://segmentfault.com/a/1190000039868496 这个例子的流程如下：开启本地事务发送Prepare消息执行Prepare成功后本地事务，返回UNKNOWN RocketMq回查时，返回COMMIT，最后发送消息在这个流程中，3执行完之后，最好是要直接发送Commi

3热度

6回答

[apache/rocketmq]5.0版本什么时候发布

请问5.0版本什么时候发布？

10热度

7回答

[apache/rocketmq]线上环境出现的一次resetoffset的bug

版本：v4.2.0+ 问题描述：通过resetOffsetByTime重置位置点，发现重置位置点不能准确定位到目标的位置。相关代码：org.apache.rocketmq.store.ConsumeQueue getOffsetInQueueByTime() org.apache.rocketmq.store.CommitLog putMessages(final MessageExtBatch

10热度

5回答

[apache/rocketmq]仪表板和命令行工具 mqadmin 查看生产者列表错误

使用rocketmq dashboard查看生产者列表的时候，选择topic并输入生产者组名，查询返回了所有topic的生产者，并没有限制topic。命令行工具mqadmin也存在同样的问题

10热度

5回答

[apache/rocketmq]rocketmq在使用起来比kafka要复杂

rocketmq在使用起来比kafka要复杂，比如主从节点的切换：rocketmq需要额外的配置，kafka却自动完成，不需要引入Dledger之类的中间件，另外一个就是rocketmq在k8s的部署，也没有像kafka那么完善的支持，比如helm.sh官网上rocketmq必须通过rocketmq operator，但是kafka却有bitnami kafka可以使用 rocketmq易用性希