apache

6热度

9回答

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

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

10热度

5回答

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

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

8热度

5回答

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

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

5热度

6回答

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

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

2热度

7回答

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

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

6热度

5回答

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

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

8热度

5回答

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

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