rocketmq

rocketmq copied to clipboard

[#3907]perf: Make `lastUpdateTimestamp` volatile so that the expiration task would see this quicker

1

reference Eureka #3907

xdshent

[ISSUE #4323] Filter example add the default NamesrvAddr

2

fix : #4323 **Make sure set the target branch to `develop`** ## What is the purpose of the change XXXXX ## Brief changelog XX ## Verifying this change XXXX Follow...

li-xiao-shuang

there may be a bug in pop consumer mode.

1

BUG REPORT There may be another problem in HA mode, when we put ck or ack message to store, SLAVE_NOT_AVAILABLE and FLUSH_SLAVE_TIMEOUT are considered to be successfully synchronized to slave....

fujian-zfj

Here is the situation. there is a name server cluster including ns1 and ns2. broker cluster including b1, b2, b3. if ns1 is diconnected with b3, and ns2 is disconnected...

jason199101

delay offset becomes negative after topic is re-created

5

version：4.7 View the offset consumption through the console as follows：  storeerr.log:  After deleting the topic and rebuilding for a period of time, the above scenario will be reproduced,...

freedom-Li

[ISSUE #4382]Namesrv nearby route

17

### RocketMQ同机房就近生产和消费机制。 RocketMQ注册、发现机制 - Broker - 间隔30秒发送broker上的Topic全量信息到所有Nameserv。broker启动的时候也是延迟注册到Namesrv上的。当有topic发生变更时TopicConfigManager.dataVersion发生变更。 - 当有topic创建和更新时，broker立刻发送Topic增量信息到所有Namesrv。同时触发Namesrv的BrokerLiveInfo.dataVersion发生变更。 - Namesrv - 保存集群和broker关系、broker信息（brokerName和地址）、broker真实连接和topic版本号，topic信息。 - 调度线程每10秒钟检查一次，如果发现一个broker 120秒都没有更新注册信息，则删除和这个broker相关的所有信息。 - Producer&Consumer - Producer第一次发送Message时，会同步向namesrv请求topic路由信息 - Consumer启动过程中会向namesrv请求topic路由信息 - 每隔30秒向namesrv拉取一次topic路由信息，根据路由信息内容（不是版本号）判断是否变化，发生变化更新 - 总结： Producer第一次发送消息时会同步向namesrv请求topic路由信息，然后默认轮询往每个Queue发送消息。 Consumer启动时获取topic路由信息，然后请求broker获取consumer实例列表，最后根据consumer的数量和负载均衡算法给consumer分配queue。 ### 实现rocketmq同机房就近生产和消费：...

lwclover

[ISSUE #3998] Enable Github Action for CI Build

3

Fixes #3998

aaron-ai

[ISSUE #4771]In HA mode, if you do not truncate consumerOffsetMap, it may cause a bug

3

BUG REPORT close #4771 

fujian-zfj

RocketMQ verison ： 4.7.0 1. The seek method in DefaultLitePullConsumerImpl defaults to the rebrance method. However, if I want to customize the MessageQueueListener, it seems that I cannot use the...

sunxiaojian

isSpaceToDelete method is not robust enough when some config change

4

isSpaceToDelete method is not robust enough when some config change 

BiggerBrain