apache

    6热度

    9回答

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

    10热度

    5回答

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

    8热度

    5回答

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

    5热度

    6回答

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

    2热度

    7回答

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

    6热度

    5回答

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

    8热度

    5回答

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