ShannonDing merged PR #931:
URL: https://github.com/apache/rocketmq-externals/pull/931
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscr...@r
GitHub user cserwen edited a comment on the discussion:
集群消费模式下,是否在某些情况下,存在同一个队列被 同一个消费组的 多个消费者消费的情况?
RocketMQ 支持 at-least-once 语义,至少投递一次,不保证只消费一次,然后上述情况是会出现的
- Rebalance 是最终一致,除了服务端主动通知,各个 consumer 会定时查询 Topic 分区信息和消费者信息,来计算自己应该消费的队列
- 除了你提到的这些情况,还可能多个 consumer 的 clientID 一样,然后计算出相同的分区,也会重复,由于
GitHub user cserwen added a comment to the discussion:
集群消费模式下,是否在某些情况下,存在同一个队列被 同一个消费组的 多个消费者消费的情况?
RocketMQ 支持 at-least-once 语义,至少投递一次,不保证只消费一次,然后上述情况是会出现的
- Rebalance 是最终一致,各个 consumer 会定时查询 Topic 分区信息和 订阅组消费者信息,来计算自己应该消费的队列
- 除了你提到的这些情况,还可能多个 consumer 的 clientID 一样,然后计算出相同的分区,也会重复,由于 push
Hi RocketMQ Community,
I hope you are all doing well. This is the discussion for the release of
RocketMQ Exporter 0.0.2. RocketMQ Exporter has not been formally released yet,
but for the long term, it's necessary to make it under versioned management and
release. Therefore, I would like to sta
Hi everyone,
I hope you are all doing well. It has been more than three months since our
last release of version 5.1.4, during which we have fixed numerous issues to
enhance stability. Additionally, support for the million-level queue,
RIP-66[1], has also been merged into the trunk. Therefore,
Hi everyone,
This is an email discussing the release of Apache RocketMQ 4.9.8. Kindly
respond to this email if you have any suggestions or any important bugs that
require merging.
Best regards,
RongtongJin
RongtongJin opened a new pull request, #931:
URL: https://github.com/apache/rocketmq-externals/pull/931
## What is the purpose of the change
Upgrade fastjson version
## Brief changelog
Upgrade fastjson version
## Verifying this change
Follow this
GitHub user leizhiyuan added a comment to the discussion: 在公有云上部署本地连接不上
说明你启动的可能不是这个配置文件,可以看看自己启动之后,通过./bin/mqadmin getBrokerConfig -b "xxx:10091"
|grep brokerIP1
看看brokerip1是不是对的。
GitHub link:
https://github.com/apache/rocketmq/discussions/7621#discussioncomment-8130742
This is an aut
GitHub user leizhiyuan added a comment to the discussion:
org.apache.rocketmq.store.schedule.ScheduleMessageService.DeliverDelayedMessageTimerTask#messageTimeup
Here is a bitwise logic
GitHub link:
https://github.com/apache/rocketmq/discussions/7754#discussioncomment-8130553
This is an