apache / rocketmq
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 1,488 files with 169,271 lines of code.
    • 10 files changed more than 100 times (20,190 lines of code)
    • 34 files changed 51-100 times (22,483 lines of code)
    • 118 files changed 21-50 times (33,542 lines of code)
    • 444 files changed 6-20 times (48,467 lines of code)
    • 882 files changed 1-5 times (44,589 lines of code)
11% | 13% | 19% | 28% | 26%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 1,488 files with 169,271 lines of code.
    • 62 files changed by more than 25 contributors (48,310 lines of code)
    • 194 files changed by 11-25 contributors (40,515 lines of code)
    • 288 files changed by 6-10 contributors (27,250 lines of code)
    • 437 files changed by 2-5 contributors (31,438 lines of code)
    • 507 files changed by 1 contributor (21,758 lines of code)
28% | 23% | 16% | 18% | 12%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, md, xml, yaml, sh, cmd, properties, json, py, sql, bzl, gitignore, txt
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java12% | 13% | 20% | 28% | 26%
xml0% | 0% | 4% | 73% | 21%
py0% | 0% | 0% | 0% | 100%
bzl0% | 0% | 0% | 0% | 100%
sql0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
store21% | 7% | 31% | 25% | 13%
client25% | 25% | 20% | 18% | 10%
broker16% | 18% | 26% | 24% | 14%
tools13% | 10% | 11% | 44% | 20%
common11% | 18% | 6% | 38% | 24%
remoting0% | 12% | 5% | 10% | 71%
namesrv0% | 63% | 21% | 6% | 8%
proxy0% | 7% | 29% | 44% | 19%
controller0% | 0% | 35% | 20% | 44%
example0% | 0% | 30% | 53% | 16%
tieredstore0% | 0% | 7% | 37% | 55%
distribution0% | 0% | 66% | 33% | 0%
filter0% | 0% | 0% | 53% | 46%
container0% | 0% | 0% | 95% | 4%
openmessaging0% | 0% | 0% | 67% | 32%
auth0% | 0% | 0% | 11% | 88%
srvutil0% | 0% | 0% | 100% | 0%
style0% | 0% | 0% | 29% | 70%
dev0% | 0% | 0% | 0% | 100%
bazel0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
DefaultMessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 2709 218 2016-12-27 2025-04-16 198 99 yukon@apache.org 707364882@qq.com
BrokerController.java
in broker/src/main/java/org/apache/rocketmq/broker
 2119 177 2016-12-27 2025-04-30 188 87 yukon@apache.org dingshuangxi888@gmail.com
AdminBrokerProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 2976 97 2016-12-27 2025-05-06 157 87 yukon@apache.org 707364882@qq.com
MQClientAPIImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 3092 145 2016-12-27 2025-04-30 152 85 yukon@apache.org dingshuangxi888@gmail.com
BrokerConfig.java
in common/src/main/java/org/apache/rocketmq/common
 1424 399 2016-12-27 2025-04-30 141 63 yukon@apache.org dingshuangxi888@gmail.com
CommitLog.java
in store/src/main/java/org/apache/rocketmq/store
 1970 114 2016-12-27 2025-04-01 135 83 yukon@apache.org ymwneu@126.com
DefaultMQProducerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/producer
 1578 100 2016-12-27 2025-03-10 132 87 yukon@apache.org gaoyf@users.noreply.github.com
MQClientInstance.java
in client/src/main/java/org/apache/rocketmq/client/impl/factory
 1183 68 2016-12-27 2025-04-11 114 72 yukon@apache.org ymwneu@126.com
DefaultMQAdminExtImpl.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 1791 142 2016-12-27 2025-04-30 111 64 yukon@apache.org dingshuangxi888@gmail.com
MessageStoreConfig.java
in store/src/main/java/org/apache/rocketmq/store/config
 1348 364 2016-12-27 2024-12-05 102 64 yukon@apache.org jamiechen.778@gmail.com
NettyRemotingClient.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 1064 60 2016-12-27 2025-02-25 100 60 yukon@apache.org xinzhuxiansheng@126.com
SendMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 593 12 2016-12-27 2024-12-09 97 59 yukon@apache.org imzs@foxmail.com
DefaultMQProducer.java
in client/src/main/java/org/apache/rocketmq/client/producer
 741 118 2016-12-27 2025-03-10 97 61 yukon@apache.org gaoyf@users.noreply.github.com
MixAll.java
in common/src/main/java/org/apache/rocketmq/common
 473 38 2016-12-27 2025-04-01 96 66 yukon@apache.org ymwneu@126.com
MQAdminStartup.java
in tools/src/main/java/org/apache/rocketmq/tools/command
 280 6 2016-12-27 2025-04-30 94 53 yukon@apache.org dingshuangxi888@gmail.com
DefaultMQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 820 143 2016-12-27 2025-04-30 88 54 yukon@apache.org dingshuangxi888@gmail.com
DefaultMQPushConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1325 87 2016-12-27 2024-12-15 87 56 yukon@apache.org mxsm@apache.org
BrokerOuterAPI.java
in broker/src/main/java/org/apache/rocketmq/broker/out
 1271 63 2016-12-27 2024-08-02 85 46 yukon@apache.org imzs@foxmail.com
DefaultLitePullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1071 92 2019-07-30 2024-11-08 82 51 794220751@qq.com 1181963012mw@gmail.com
MQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 322 - 2016-12-27 2025-04-30 79 48 yukon@apache.org dingshuangxi888@gmail.com
PopMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 943 36 2021-03-09 2025-05-06 74 34 ayanamist@gmail.com 707364882@qq.com
RouteInfoManager.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo
 1071 66 2016-12-27 2024-03-18 74 48 yukon@apache.org 64068328+caizhaomin1@users....
NettyRemotingAbstract.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 552 27 2016-12-27 2025-02-24 73 46 yukon@apache.org zsjperiod@foxmail.com
UtilAll.java
in common/src/main/java/org/apache/rocketmq/common
 638 52 2016-12-27 2024-08-15 73 51 yukon@apache.org 58294989+zekai-li@users.nor...
NettyRemotingServer.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 658 59 2016-12-27 2025-02-24 73 43 yukon@apache.org zsjperiod@foxmail.com
DefaultMQPushConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 486 102 2016-12-27 2024-08-30 72 37 yukon@apache.org 845238369@qq.com
ConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store
 979 57 2016-12-27 2024-10-23 72 46 yukon@apache.org lizhanhui@apache.org
DLedgerCommitLog.java
in store/src/main/java/org/apache/rocketmq/store/dledger
 910 50 2018-12-03 2025-03-17 71 50 dongeforever@apache.org wuxingcan.wxc@alibaba-inc.com
TopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 624 41 2016-12-27 2025-02-26 68 42 yukon@apache.org 2573259572@qq.com
DefaultMQPullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 724 70 2016-12-27 2024-11-29 62 47 yukon@apache.org wuxingcan.wxc@alibaba-inc.com
AsyncTraceDispatcher.java
in client/src/main/java/org/apache/rocketmq/client/trace
 351 29 2018-12-28 2025-04-30 61 50 dongeforever@apache.org wuxingcan.wxc@alibaba-inc.com
ClientConfig.java
in client/src/main/java/org/apache/rocketmq/client
 414 71 2016-12-27 2024-07-29 61 41 yukon@apache.org 43874697+letletme@users.nor...
MQVersion.java
in common/src/main/java/org/apache/rocketmq/common
 633 2 2016-12-27 2025-05-06 61 26 yukon@apache.org 707364882@qq.com
ConsumeMessageOrderlyService.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 485 25 2016-12-27 2024-05-16 60 41 yukon@apache.org 65004897+willhow-gao@users....
ProxyConfig.java
in proxy/src/main/java/org/apache/rocketmq/proxy/config
 1136 305 2022-03-16 2025-04-30 60 23 jixiang.jjx@alibaba-inc.com dingshuangxi888@gmail.com
DefaultRequestProcessor.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/processor
 566 30 2016-12-27 2024-01-29 59 35 yukon@apache.org ljbmxsm@gmail.com
PullMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 769 16 2016-12-27 2025-04-01 59 37 yukon@apache.org ymwneu@126.com
MessageDecoder.java
in common/src/main/java/org/apache/rocketmq/common/message
 565 22 2016-12-27 2024-12-05 58 41 yukon@apache.org lizhanhui@apache.org
MessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 166 2 2016-12-27 2024-12-10 55 35 yukon@apache.org 36399867+guyinyou@users.nor...
AbstractSendMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 495 18 2016-12-27 2025-04-09 55 37 yukon@apache.org ymwneu@126.com
HAService.java
in store/src/main/java/org/apache/rocketmq/store/ha
 39 4 2016-12-27 2023-10-14 52 37 yukon@apache.org 2573259572@qq.com
BrokerStartup.java
in broker/src/main/java/org/apache/rocketmq/broker
 252 13 2016-12-27 2024-03-18 51 31 yukon@apache.org dingshuangxi888@gmail.com
ConsumeMessageConcurrentlyService.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 386 21 2016-12-27 2024-05-07 51 36 yukon@apache.org jjhfen00@163.com
ReplicasManager.java
in broker/src/main/java/org/apache/rocketmq/broker/controller
 681 45 2022-06-16 2024-10-14 51 20 jinrongtong16@mails.ucas.ac.cn luozongle@hotmail.com
MQAdminImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 404 22 2016-12-27 2024-08-30 48 34 yukon@apache.org jinrongtong16@mails.ucas.ac.cn
RebalanceImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 651 27 2016-12-27 2024-12-25 48 34 yukon@apache.org 125714719+3424672656@users....
DefaultLitePullConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 378 84 2019-07-30 2024-07-29 47 30 794220751@qq.com 43874697+letletme@users.nor...
PopReviveService.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 624 22 2021-03-09 2025-05-06 47 26 ayanamist@gmail.com 707364882@qq.com
NamesrvStartup.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv
 188 14 2016-12-27 2024-03-16 46 30 yukon@apache.org 41882826+oopooa@users.norep...
MappedFileQueue.java
in store/src/main/java/org/apache/rocketmq/store
 739 51 2016-12-27 2023-12-20 46 29 yukon@apache.org 43713766+evanmi@users.norep...
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
DefaultMessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 2709 218 2016-12-27 2025-04-16 198 99 yukon@apache.org 707364882@qq.com
BrokerController.java
in broker/src/main/java/org/apache/rocketmq/broker
 2119 177 2016-12-27 2025-04-30 188 87 yukon@apache.org dingshuangxi888@gmail.com
AdminBrokerProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 2976 97 2016-12-27 2025-05-06 157 87 yukon@apache.org 707364882@qq.com
DefaultMQProducerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/producer
 1578 100 2016-12-27 2025-03-10 132 87 yukon@apache.org gaoyf@users.noreply.github.com
MQClientAPIImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 3092 145 2016-12-27 2025-04-30 152 85 yukon@apache.org dingshuangxi888@gmail.com
CommitLog.java
in store/src/main/java/org/apache/rocketmq/store
 1970 114 2016-12-27 2025-04-01 135 83 yukon@apache.org ymwneu@126.com
MQClientInstance.java
in client/src/main/java/org/apache/rocketmq/client/impl/factory
 1183 68 2016-12-27 2025-04-11 114 72 yukon@apache.org ymwneu@126.com
MixAll.java
in common/src/main/java/org/apache/rocketmq/common
 473 38 2016-12-27 2025-04-01 96 66 yukon@apache.org ymwneu@126.com
DefaultMQAdminExtImpl.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 1791 142 2016-12-27 2025-04-30 111 64 yukon@apache.org dingshuangxi888@gmail.com
MessageStoreConfig.java
in store/src/main/java/org/apache/rocketmq/store/config
 1348 364 2016-12-27 2024-12-05 102 64 yukon@apache.org jamiechen.778@gmail.com
BrokerConfig.java
in common/src/main/java/org/apache/rocketmq/common
 1424 399 2016-12-27 2025-04-30 141 63 yukon@apache.org dingshuangxi888@gmail.com
DefaultMQProducer.java
in client/src/main/java/org/apache/rocketmq/client/producer
 741 118 2016-12-27 2025-03-10 97 61 yukon@apache.org gaoyf@users.noreply.github.com
NettyRemotingClient.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 1064 60 2016-12-27 2025-02-25 100 60 yukon@apache.org xinzhuxiansheng@126.com
SendMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 593 12 2016-12-27 2024-12-09 97 59 yukon@apache.org imzs@foxmail.com
DefaultMQPushConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1325 87 2016-12-27 2024-12-15 87 56 yukon@apache.org mxsm@apache.org
DefaultMQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 820 143 2016-12-27 2025-04-30 88 54 yukon@apache.org dingshuangxi888@gmail.com
MQAdminStartup.java
in tools/src/main/java/org/apache/rocketmq/tools/command
 280 6 2016-12-27 2025-04-30 94 53 yukon@apache.org dingshuangxi888@gmail.com
DefaultLitePullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1071 92 2019-07-30 2024-11-08 82 51 794220751@qq.com 1181963012mw@gmail.com
UtilAll.java
in common/src/main/java/org/apache/rocketmq/common
 638 52 2016-12-27 2024-08-15 73 51 yukon@apache.org 58294989+zekai-li@users.nor...
DLedgerCommitLog.java
in store/src/main/java/org/apache/rocketmq/store/dledger
 910 50 2018-12-03 2025-03-17 71 50 dongeforever@apache.org wuxingcan.wxc@alibaba-inc.com
AsyncTraceDispatcher.java
in client/src/main/java/org/apache/rocketmq/client/trace
 351 29 2018-12-28 2025-04-30 61 50 dongeforever@apache.org wuxingcan.wxc@alibaba-inc.com
MQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 322 - 2016-12-27 2025-04-30 79 48 yukon@apache.org dingshuangxi888@gmail.com
RouteInfoManager.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo
 1071 66 2016-12-27 2024-03-18 74 48 yukon@apache.org 64068328+caizhaomin1@users....
DefaultMQPullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 724 70 2016-12-27 2024-11-29 62 47 yukon@apache.org wuxingcan.wxc@alibaba-inc.com
BrokerOuterAPI.java
in broker/src/main/java/org/apache/rocketmq/broker/out
 1271 63 2016-12-27 2024-08-02 85 46 yukon@apache.org imzs@foxmail.com
NettyRemotingAbstract.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 552 27 2016-12-27 2025-02-24 73 46 yukon@apache.org zsjperiod@foxmail.com
ConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store
 979 57 2016-12-27 2024-10-23 72 46 yukon@apache.org lizhanhui@apache.org
NettyRemotingServer.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 658 59 2016-12-27 2025-02-24 73 43 yukon@apache.org zsjperiod@foxmail.com
TopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 624 41 2016-12-27 2025-02-26 68 42 yukon@apache.org 2573259572@qq.com
ClientConfig.java
in client/src/main/java/org/apache/rocketmq/client
 414 71 2016-12-27 2024-07-29 61 41 yukon@apache.org 43874697+letletme@users.nor...
ConsumeMessageOrderlyService.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 485 25 2016-12-27 2024-05-16 60 41 yukon@apache.org 65004897+willhow-gao@users....
MessageDecoder.java
in common/src/main/java/org/apache/rocketmq/common/message
 565 22 2016-12-27 2024-12-05 58 41 yukon@apache.org lizhanhui@apache.org
DefaultMQPushConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 486 102 2016-12-27 2024-08-30 72 37 yukon@apache.org 845238369@qq.com
PullMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 769 16 2016-12-27 2025-04-01 59 37 yukon@apache.org ymwneu@126.com
AbstractSendMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 495 18 2016-12-27 2025-04-09 55 37 yukon@apache.org ymwneu@126.com
HAService.java
in store/src/main/java/org/apache/rocketmq/store/ha
 39 4 2016-12-27 2023-10-14 52 37 yukon@apache.org 2573259572@qq.com
ConsumeMessageConcurrentlyService.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 386 21 2016-12-27 2024-05-07 51 36 yukon@apache.org jjhfen00@163.com
DefaultRequestProcessor.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/processor
 566 30 2016-12-27 2024-01-29 59 35 yukon@apache.org ljbmxsm@gmail.com
MessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 166 2 2016-12-27 2024-12-10 55 35 yukon@apache.org 36399867+guyinyou@users.nor...
PopMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 943 36 2021-03-09 2025-05-06 74 34 ayanamist@gmail.com 707364882@qq.com
RebalanceImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 651 27 2016-12-27 2024-12-25 48 34 yukon@apache.org 125714719+3424672656@users....
MQAdminImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 404 22 2016-12-27 2024-08-30 48 34 yukon@apache.org jinrongtong16@mails.ucas.ac.cn
BrokerStartup.java
in broker/src/main/java/org/apache/rocketmq/broker
 252 13 2016-12-27 2024-03-18 51 31 yukon@apache.org dingshuangxi888@gmail.com
DefaultMQPullConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 337 65 2016-12-27 2024-11-29 45 31 yukon@apache.org wuxingcan.wxc@alibaba-inc.com
TransactionalMessageServiceImpl.java
in broker/src/main/java/org/apache/rocketmq/broker/transaction/queue
 616 30 2018-07-15 2025-01-08 44 31 39583243+duhengforever@user... 51823604+lilmosey@users.nor...
RemotingHelper.java
in remoting/src/main/java/org/apache/rocketmq/remoting/common
 309 19 2016-12-27 2024-11-14 44 31 yukon@apache.org wuxingcan.wxc@alibaba-inc.com
PullAPIWrapper.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 319 16 2016-12-27 2024-01-12 43 31 yukon@apache.org zhouxiang.zzx@alibaba-inc.com
DefaultLitePullConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 378 84 2019-07-30 2024-07-29 47 30 794220751@qq.com 43874697+letletme@users.nor...
NamesrvStartup.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv
 188 14 2016-12-27 2024-03-16 46 30 yukon@apache.org 41882826+oopooa@users.norep...
ClientRemotingProcessor.java
in client/src/main/java/org/apache/rocketmq/client/impl
 245 11 2016-12-27 2024-05-07 44 30 yukon@apache.org jjhfen00@163.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
MqClientAdminImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/admin
 395 18 2023-04-28 2023-04-28 1 1 zhouxzhan@apache.org zhouxzhan@apache.org
ConsumerOffsetManagerV2.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 320 14 2024-10-28 2024-12-02 3 1 lizhanhui@apache.org lizhanhui@apache.org
MessageStoreConfig.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore
 290 75 2024-03-18 2024-08-06 2 1 707364882@qq.com 707364882@qq.com
JRaftControllerStateMachine.java
in controller/src/main/java/org/apache/rocketmq/controller/impl
 288 22 2024-01-29 2024-01-29 1 1 53958801+yulangz@users.nore... 53958801+yulangz@users.nore...
ConsumerRunningInfo.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body
 273 18 2022-11-11 2022-11-11 1 1 admin@lv5.moe admin@lv5.moe
FileSegment.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider
 271 27 2024-03-18 2024-11-26 2 1 707364882@qq.com 707364882@qq.com
PopConsumerCache.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 242 25 2024-12-20 2024-12-20 1 1 707364882@qq.com 707364882@qq.com
AuthorizationMetadataManagerImpl.java
in auth/src/main/java/org/apache/rocketmq/auth/authorization/manager
 238 14 2024-03-18 2024-03-25 2 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
ProxyAndTlsProtocolNegotiator.java
in proxy/src/main/java/org/apache/rocketmq/proxy/grpc
 233 15 2023-07-04 2024-03-18 6 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AclUtils.java
in client/src/main/java/org/apache/rocketmq/acl/common
 229 20 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
JRaftController.java
in controller/src/main/java/org/apache/rocketmq/controller/impl
 229 25 2024-01-29 2024-01-29 1 1 53958801+yulangz@users.nore... 53958801+yulangz@users.nore...
RaftReplicasInfoManager.java
in controller/src/main/java/org/apache/rocketmq/controller/impl/manager
 201 10 2024-01-29 2024-01-29 1 1 53958801+yulangz@users.nore... 53958801+yulangz@users.nore...
AuthConfig.java
in auth/src/main/java/org/apache/rocketmq/auth/config
 193 53 2024-03-18 2024-03-18 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
ConfigStorage.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 191 13 2024-10-28 2024-12-02 4 1 lizhanhui@apache.org lizhanhui@apache.org
AuthMigrator.java
in auth/src/main/java/org/apache/rocketmq/auth/migration
 191 9 2024-03-18 2025-04-30 3 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
BitsArray.java
in filter/src/main/java/org/apache/rocketmq/filter/util
 186 26 2017-04-21 2017-04-21 1 1 liuxuedee@gmail.com liuxuedee@gmail.com
PosixFileSegment.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider
 185 11 2024-03-18 2024-11-26 3 1 707364882@qq.com 707364882@qq.com
TopicRouteData.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route
 175 17 2022-11-11 2022-11-11 1 1 admin@lv5.moe admin@lv5.moe
LocalAuthorizationMetadataProvider.java
in auth/src/main/java/org/apache/rocketmq/auth/authorization/provider
 167 8 2024-03-18 2024-03-20 2 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
RecallMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 157 5 2024-12-09 2024-12-27 2 1 imzs@foxmail.com imzs@foxmail.com
LogicQueueMappingItem.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic
 155 28 2022-11-11 2022-11-11 1 1 admin@lv5.moe admin@lv5.moe
CommitLogInputStream.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/stream
 151 8 2024-03-18 2024-03-18 1 1 707364882@qq.com 707364882@qq.com
TopicConfigManagerV2.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 145 11 2024-10-28 2024-12-02 3 1 lizhanhui@apache.org lizhanhui@apache.org
AdaptiveBackOffSpinLockImpl.java
in store/src/main/java/org/apache/rocketmq/store/lock
 143 15 2024-10-23 2024-10-23 1 1 125714719+3424672656@users.... 125714719+3424672656@users....
SubscriptionGroupManagerV2.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 142 10 2024-10-28 2024-12-02 4 1 lizhanhui@apache.org lizhanhui@apache.org
DefaultJoranConfiguratorExt.java
in common/src/main/java/org/apache/rocketmq/common/logging
 137 8 2022-11-21 2022-11-21 1 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
SubscriptionData.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat
 136 22 2022-11-11 2022-11-11 1 1 admin@lv5.moe admin@lv5.moe
LocalAuthenticationMetadataProvider.java
in auth/src/main/java/org/apache/rocketmq/auth/authentication/provider
 135 8 2024-03-18 2024-03-20 2 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
FileSegmentInputStream.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/stream
 134 11 2024-03-18 2024-03-18 1 1 707364882@qq.com 707364882@qq.com
Resource.java
in auth/src/main/java/org/apache/rocketmq/auth/authorization/model
 131 16 2024-03-18 2024-03-18 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
HARuntimeInfo.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body
 130 34 2022-11-11 2022-11-11 1 1 admin@lv5.moe admin@lv5.moe
PopConsumerRocksdbStore.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 129 8 2024-12-20 2025-01-08 3 1 707364882@qq.com 707364882@qq.com
AclAuthorizationHandler.java
in auth/src/main/java/org/apache/rocketmq/auth/authorization/chain
 127 7 2024-03-18 2024-03-25 2 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
PopConsumerContext.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 125 20 2024-12-20 2025-03-15 2 1 707364882@qq.com 707364882@qq.com
AuthenticationFactory.java
in auth/src/main/java/org/apache/rocketmq/auth/authentication/factory
 124 10 2024-03-18 2024-03-25 2 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
PullMessageResponseHeader.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header
 123 19 2022-11-11 2022-11-11 1 1 admin@lv5.moe admin@lv5.moe
SessionCredentials.java
in client/src/main/java/org/apache/rocketmq/acl/common
 122 15 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
MessageFormatUtil.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/util
 119 12 2024-03-18 2024-03-18 1 1 707364882@qq.com 707364882@qq.com
PlainAccessResource.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 116 27 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
RocksDBStoreMetricsManager.java
in store/src/main/java/org/apache/rocketmq/store/metrics
 114 2 2024-01-22 2024-01-22 1 1 juntao.jjt@alibaba-inc.com juntao.jjt@alibaba-inc.com
ProcessQueueInfo.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body
 114 29 2022-11-11 2022-11-11 1 1 admin@lv5.moe admin@lv5.moe
FileSegmentMetadata.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/entity
 114 23 2024-03-18 2024-03-18 1 1 707364882@qq.com 707364882@qq.com
PlainPermissionManager.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 110 5 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
UpdateAclSubCommand.java
in tools/src/main/java/org/apache/rocketmq/tools/command/auth
 105 4 2024-03-18 2024-03-18 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
CreateAclSubCommand.java
in tools/src/main/java/org/apache/rocketmq/tools/command/auth
 105 4 2024-03-18 2024-03-18 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
DefaultAuthenticationContextBuilder.java
in auth/src/main/java/org/apache/rocketmq/auth/authentication/builder
 105 3 2024-03-18 2024-05-09 2 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
ConfigHelper.java
in common/src/main/java/org/apache/rocketmq/common/config
 104 3 2024-10-18 2024-12-02 3 1 lizhanhui@apache.org lizhanhui@apache.org
MessageQueueForC.java
in common/src/main/java/org/apache/rocketmq/common/message
 101 13 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ListAclSubCommand.java
in tools/src/main/java/org/apache/rocketmq/tools/command/auth
 100 5 2024-03-18 2024-03-18 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
ListEventSerializer.java
in controller/src/main/java/org/apache/rocketmq/controller/impl/event
 100 8 2024-01-29 2024-01-29 1 1 53958801+yulangz@users.nore... 53958801+yulangz@users.nore...
Correlations

File Size vs. Number of Changes: 1490 points

common/src/main/java/org/apache/rocketmq/common/MQVersion.java x: 633 lines of code y: 61 # changes broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java x: 116 lines of code y: 4 # changes broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java x: 484 lines of code y: 18 # changes broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java x: 146 lines of code y: 3 # changes broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java x: 599 lines of code y: 7 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java x: 416 lines of code y: 31 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java x: 2976 lines of code y: 157 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java x: 307 lines of code y: 26 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java x: 769 lines of code y: 30 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java x: 943 lines of code y: 74 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java x: 624 lines of code y: 47 # changes broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java x: 204 lines of code y: 12 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java x: 207 lines of code y: 3 # changes store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java x: 148 lines of code y: 15 # changes broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java x: 132 lines of code y: 5 # changes broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java x: 208 lines of code y: 6 # changes broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManager.java x: 128 lines of code y: 5 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java x: 227 lines of code y: 6 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java x: 367 lines of code y: 8 # changes client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java x: 351 lines of code y: 61 # changes auth/src/main/java/org/apache/rocketmq/auth/migration/AuthMigrator.java x: 191 lines of code y: 3 # changes auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AccessResource.java x: 3 lines of code y: 1 # changes auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AclConfig.java x: 25 lines of code y: 1 # changes auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessConfig.java x: 86 lines of code y: 1 # changes auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessData.java x: 68 lines of code y: 1 # changes auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessResource.java x: 116 lines of code y: 1 # changes auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainPermissionManager.java x: 110 lines of code y: 1 # changes broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java x: 2119 lines of code y: 188 # changes client/src/main/java/org/apache/rocketmq/acl/common/AclClientRPCHook.java x: 33 lines of code y: 1 # changes client/src/main/java/org/apache/rocketmq/acl/common/AclConstants.java x: 10 lines of code y: 1 # changes client/src/main/java/org/apache/rocketmq/acl/common/AclException.java x: 39 lines of code y: 1 # changes client/src/main/java/org/apache/rocketmq/acl/common/AclSigner.java x: 63 lines of code y: 1 # changes client/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java x: 229 lines of code y: 1 # changes client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java x: 122 lines of code y: 1 # changes client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java x: 3092 lines of code y: 152 # changes common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java x: 1424 lines of code y: 141 # changes proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java x: 194 lines of code y: 35 # changes proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java x: 1136 lines of code y: 60 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java x: 77 lines of code y: 23 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java x: 320 lines of code y: 14 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/AuthenticationPipeline.java x: 40 lines of code y: 5 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java x: 161 lines of code y: 19 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/ResponseCode.java x: 64 lines of code y: 9 # changes tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java x: 820 lines of code y: 88 # changes tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java x: 1791 lines of code y: 111 # changes tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java x: 322 lines of code y: 79 # changes tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java x: 280 lines of code y: 94 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java x: 53 lines of code y: 4 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java x: 354 lines of code y: 7 # changes broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java x: 357 lines of code y: 32 # changes store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java x: 256 lines of code y: 14 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java x: 355 lines of code y: 31 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java x: 411 lines of code y: 6 # changes store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java x: 2709 lines of code y: 198 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java x: 145 lines of code y: 8 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelAttributeHelper.java x: 51 lines of code y: 1 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java x: 282 lines of code y: 38 # changes client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java x: 65 lines of code y: 19 # changes client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java x: 1183 lines of code y: 114 # changes broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java x: 133 lines of code y: 18 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java x: 139 lines of code y: 10 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsHelper.java x: 178 lines of code y: 14 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java x: 495 lines of code y: 55 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java x: 122 lines of code y: 22 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/TopicStatsTable.java x: 21 lines of code y: 2 # changes store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java x: 698 lines of code y: 40 # changes tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java x: 91 lines of code y: 11 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java x: 438 lines of code y: 31 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java x: 769 lines of code y: 59 # changes broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java x: 321 lines of code y: 32 # changes common/src/main/java/org/apache/rocketmq/common/MixAll.java x: 473 lines of code y: 96 # changes broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java x: 174 lines of code y: 13 # changes store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java x: 139 lines of code y: 17 # changes common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItem.java x: 54 lines of code y: 14 # changes common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java x: 101 lines of code y: 23 # changes common/src/main/java/org/apache/rocketmq/common/stats/StatsItem.java x: 206 lines of code y: 20 # changes common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java x: 225 lines of code y: 27 # changes store/src/main/java/org/apache/rocketmq/store/CommitLog.java x: 1970 lines of code y: 135 # changes store/src/main/java/org/apache/rocketmq/store/index/IndexService.java x: 321 lines of code y: 23 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java x: 266 lines of code y: 19 # changes store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java x: 910 lines of code y: 71 # changes store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueStore.java x: 444 lines of code y: 10 # changes broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java x: 697 lines of code y: 28 # changes broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerContext.java x: 125 lines of code y: 2 # changes client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java x: 1578 lines of code y: 132 # changes client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java x: 741 lines of code y: 97 # changes example/src/main/java/org/apache/rocketmq/example/simple/PopConsumer.java x: 45 lines of code y: 2 # changes store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java x: 1673 lines of code y: 36 # changes broker/src/main/java/org/apache/rocketmq/broker/BrokerPathConfigHelper.java x: 48 lines of code y: 21 # changes broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerLagCalculator.java x: 444 lines of code y: 15 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java x: 189 lines of code y: 26 # changes client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java x: 615 lines of code y: 10 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/NotificationResponseHeader.java x: 24 lines of code y: 2 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java x: 410 lines of code y: 21 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreFetcherImpl.java x: 378 lines of code y: 8 # changes tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java x: 248 lines of code y: 22 # changes broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java x: 219 lines of code y: 34 # changes broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java x: 624 lines of code y: 68 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java x: 1064 lines of code y: 100 # changes container/src/main/java/org/apache/rocketmq/container/InnerBrokerController.java x: 143 lines of code y: 14 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java x: 166 lines of code y: 21 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManagerFactory.java x: 22 lines of code y: 4 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java x: 552 lines of code y: 73 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java x: 658 lines of code y: 73 # changes filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParser.java x: 429 lines of code y: 11 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java x: 75 lines of code y: 16 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ExportRocksDBConfigToJsonRequestHeader.java x: 69 lines of code y: 2 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumeStatsRequestHeader.java x: 67 lines of code y: 4 # changes store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java x: 367 lines of code y: 15 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/AckMessageActivity.java x: 174 lines of code y: 17 # changes common/src/main/java/org/apache/rocketmq/common/config/AbstractRocksDBStorage.java x: 495 lines of code y: 13 # changes store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueOffsetTable.java x: 555 lines of code y: 3 # changes tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataInRocksDBCommand.java x: 108 lines of code y: 5 # changes tools/src/main/java/org/apache/rocketmq/tools/command/metadata/RocksDBConfigToJsonCommand.java x: 271 lines of code y: 6 # changes broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerKVStore.java x: 10 lines of code y: 2 # changes broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java x: 129 lines of code y: 3 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java x: 616 lines of code y: 44 # changes broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopLongPollingService.java x: 356 lines of code y: 6 # changes store/src/main/java/org/apache/rocketmq/store/rocksdb/RocksDBOptionsFactory.java x: 186 lines of code y: 5 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/RecallMessageProcessor.java x: 157 lines of code y: 2 # changes common/src/main/java/org/apache/rocketmq/common/message/Message.java x: 191 lines of code y: 27 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/ProducerProcessor.java x: 224 lines of code y: 22 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/SendMessageActivity.java x: 71 lines of code y: 5 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/GroupCommitContext.java x: 40 lines of code y: 1 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreDispatcherImpl.java x: 324 lines of code y: 5 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatFileInterface.java x: 40 lines of code y: 3 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java x: 651 lines of code y: 48 # changes broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerCache.java x: 242 lines of code y: 1 # changes tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportPopRecordCommand.java x: 82 lines of code y: 1 # changes auth/src/main/java/org/apache/rocketmq/auth/authorization/builder/DefaultAuthorizationContextBuilder.java x: 465 lines of code y: 6 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java x: 1325 lines of code y: 87 # changes broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java x: 256 lines of code y: 23 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java x: 299 lines of code y: 30 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java x: 262 lines of code y: 19 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java x: 90 lines of code y: 9 # changes store/src/main/java/org/apache/rocketmq/store/MessageStore.java x: 166 lines of code y: 55 # changes store/src/main/java/org/apache/rocketmq/store/plugin/AbstractPluginMessageStore.java x: 531 lines of code y: 14 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java x: 593 lines of code y: 97 # changes client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java x: 87 lines of code y: 22 # changes client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java x: 107 lines of code y: 11 # changes client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java x: 211 lines of code y: 27 # changes client/src/main/java/org/apache/rocketmq/client/trace/TraceType.java x: 8 lines of code y: 11 # changes client/src/main/java/org/apache/rocketmq/client/trace/hook/DefaultRecallMessageTraceHook.java x: 57 lines of code y: 1 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/RequestMapping.java x: 38 lines of code y: 5 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/DefaultGrpcMessingActivity.java x: 128 lines of code y: 22 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java x: 424 lines of code y: 22 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessingActivity.java x: 46 lines of code y: 8 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java x: 330 lines of code y: 24 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java x: 307 lines of code y: 32 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/MessagingProcessor.java x: 284 lines of code y: 26 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/message/ClusterMessageService.java x: 244 lines of code y: 21 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalMessageService.java x: 467 lines of code y: 26 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/message/MessageService.java x: 135 lines of code y: 14 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/RecallMessageRequestHeader.java x: 50 lines of code y: 1 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/RecallMessageResponseHeader.java x: 17 lines of code y: 1 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageResponseHeader.java x: 93 lines of code y: 2 # changes srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java x: 73 lines of code y: 20 # changes store/src/main/java/org/apache/rocketmq/store/stats/LmqBrokerStatsManager.java x: 54 lines of code y: 5 # changes store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java x: 1348 lines of code y: 102 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java x: 388 lines of code y: 38 # changes client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java x: 454 lines of code y: 2 # changes client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java x: 63 lines of code y: 7 # changes client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageTraceHookImpl.java x: 69 lines of code y: 21 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java x: 565 lines of code y: 58 # changes broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConfigStorage.java x: 191 lines of code y: 4 # changes broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConsumerOffsetManagerV2.java x: 320 lines of code y: 3 # changes broker/src/main/java/org/apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java x: 142 lines of code y: 4 # changes broker/src/main/java/org/apache/rocketmq/broker/config/v2/TopicConfigManagerV2.java x: 145 lines of code y: 3 # changes common/src/main/java/org/apache/rocketmq/common/config/ConfigHelper.java x: 104 lines of code y: 3 # changes common/src/main/java/org/apache/rocketmq/common/config/ConfigRocksDBStorage.java x: 106 lines of code y: 7 # changes container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java x: 250 lines of code y: 16 # changes client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java x: 337 lines of code y: 45 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java x: 724 lines of code y: 62 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java x: 227 lines of code y: 21 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatFileFactory.java x: 39 lines of code y: 2 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatFileStore.java x: 139 lines of code y: 4 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/FileSegment.java x: 271 lines of code y: 2 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/MemoryFileSegment.java x: 79 lines of code y: 2 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/PosixFileSegment.java x: 185 lines of code y: 3 # changes common/src/main/java/org/apache/rocketmq/common/utils/IPAddressUtils.java x: 77 lines of code y: 2 # changes proxy/src/main/java/org/apache/rocketmq/proxy/common/Address.java x: 62 lines of code y: 5 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/GetTopicRouteActivity.java x: 49 lines of code y: 5 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ProxyTopicRouteData.java x: 116 lines of code y: 8 # changes proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroup.java x: 280 lines of code y: 11 # changes broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotifyMessageArrivingListener.java x: 25 lines of code y: 16 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java x: 511 lines of code y: 43 # changes store/src/main/java/org/apache/rocketmq/store/queue/AbstractConsumeQueueStore.java x: 88 lines of code y: 4 # changes store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueue.java x: 366 lines of code y: 5 # changes common/src/main/java/org/apache/rocketmq/common/constant/PermName.java x: 45 lines of code y: 17 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java x: 268 lines of code y: 17 # changes remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java x: 309 lines of code y: 44 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java x: 146 lines of code y: 25 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolTlsHelper.java x: 83 lines of code y: 3 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java x: 1071 lines of code y: 82 # changes auth/src/main/java/org/apache/rocketmq/auth/authentication/chain/DefaultAuthenticationHandler.java x: 48 lines of code y: 3 # changes store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java x: 288 lines of code y: 22 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CheckRocksdbCqWriteProgressRequestHeader.java x: 31 lines of code y: 2 # changes store/src/main/java/org/apache/rocketmq/store/RocksDBMessageStore.java x: 146 lines of code y: 6 # changes tools/src/main/java/org/apache/rocketmq/tools/command/queue/CheckRocksdbCqWriteProgressCommand.java x: 74 lines of code y: 3 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/LanguageCode.java x: 40 lines of code y: 11 # changes broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBOffsetSerializeWrapper.java x: 13 lines of code y: 1 # changes store/src/main/java/org/apache/rocketmq/store/lock/AdaptiveBackOffSpinLockImpl.java x: 143 lines of code y: 1 # changes store/src/main/java/org/apache/rocketmq/store/lock/BackOffSpinLock.java x: 75 lines of code y: 1 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyLogger.java x: 287 lines of code y: 10 # changes broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java x: 43 lines of code y: 12 # changes broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java x: 165 lines of code y: 27 # changes broker/src/main/java/org/apache/rocketmq/broker/offset/BroadcastOffsetManager.java x: 159 lines of code y: 3 # changes common/src/main/java/org/apache/rocketmq/common/ServiceThread.java x: 96 lines of code y: 27 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageExtBrokerInner.java x: 71 lines of code y: 10 # changes store/src/main/java/org/apache/rocketmq/store/AppendMessageStatus.java x: 9 lines of code y: 4 # changes store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java x: 979 lines of code y: 72 # changes store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java x: 202 lines of code y: 17 # changes store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java x: 287 lines of code y: 9 # changes store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java x: 499 lines of code y: 22 # changes store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStoreInterface.java x: 52 lines of code y: 3 # changes store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueTable.java x: 291 lines of code y: 4 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metrics/TieredStoreMetricsManager.java x: 281 lines of code y: 10 # changes common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledIncrementPrinter.java x: 209 lines of code y: 7 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicQueueMappingUtils.java x: 588 lines of code y: 4 # changes store/src/main/java/org/apache/rocketmq/store/timer/TimerLog.java x: 90 lines of code y: 8 # changes store/src/main/java/org/apache/rocketmq/store/rocksdb/ConsumeQueueRocksDBStorage.java x: 85 lines of code y: 2 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ResetOffsetRequestHeader.java x: 63 lines of code y: 4 # changes broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java x: 335 lines of code y: 20 # changes remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcClientImpl.java x: 287 lines of code y: 4 # changes broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java x: 681 lines of code y: 51 # changes broker/src/main/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java x: 100 lines of code y: 6 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java x: 303 lines of code y: 33 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/HeaderInterceptor.java x: 66 lines of code y: 10 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/pipeline/AuthenticationPipeline.java x: 53 lines of code y: 2 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java x: 152 lines of code y: 15 # changes client/src/main/java/org/apache/rocketmq/client/consumer/PopStatus.java x: 7 lines of code y: 7 # changes openmessaging/src/main/java/io/openmessaging/rocketmq/promise/DefaultPromise.java x: 178 lines of code y: 12 # changes store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java x: 262 lines of code y: 32 # changes store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java x: 305 lines of code y: 8 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java x: 479 lines of code y: 36 # changes store/src/main/java/org/apache/rocketmq/store/queue/CqUnit.java x: 75 lines of code y: 5 # changes auth/src/main/java/org/apache/rocketmq/auth/authorization/factory/AuthorizationFactory.java x: 127 lines of code y: 3 # changes broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java x: 33 lines of code y: 4 # changes client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java x: 486 lines of code y: 72 # changes client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java x: 404 lines of code y: 48 # changes tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java x: 309 lines of code y: 34 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java x: 265 lines of code y: 28 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java x: 87 lines of code y: 10 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommand.java x: 169 lines of code y: 23 # changes tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java x: 132 lines of code y: 17 # changes tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeOldCommand.java x: 105 lines of code y: 8 # changes tools/src/main/java/org/apache/rocketmq/tools/command/offset/SkipAccumulationSubCommand.java x: 102 lines of code y: 6 # changes common/src/main/java/org/apache/rocketmq/common/utils/NetworkUtil.java x: 171 lines of code y: 8 # changes common/src/main/java/org/apache/rocketmq/common/ConfigManager.java x: 66 lines of code y: 18 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/receipt/DefaultReceiptHandleManager.java x: 246 lines of code y: 6 # changes client/src/main/java/org/apache/rocketmq/client/trace/TraceBean.java x: 113 lines of code y: 11 # changes common/src/main/java/org/apache/rocketmq/common/UtilAll.java x: 638 lines of code y: 73 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ClientManagerActivity.java x: 165 lines of code y: 7 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/MessageStoreConfig.java x: 290 lines of code y: 2 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexService.java x: 15 lines of code y: 3 # changes broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java x: 1271 lines of code y: 85 # changes common/src/main/java/org/apache/rocketmq/common/stats/Stats.java x: 31 lines of code y: 5 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java x: 396 lines of code y: 16 # changes client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java x: 86 lines of code y: 11 # changes client/src/main/java/org/apache/rocketmq/client/ClientConfig.java x: 414 lines of code y: 61 # changes client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java x: 378 lines of code y: 47 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/DefaultBrokerHeartbeatManager.java x: 159 lines of code y: 6 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/RaftBrokerHeartBeatManager.java x: 230 lines of code y: 2 # changes store/src/main/java/org/apache/rocketmq/store/logfile/DefaultMappedFile.java x: 753 lines of code y: 22 # changes store/src/main/java/org/apache/rocketmq/store/queue/BatchConsumeQueue.java x: 949 lines of code y: 23 # changes store/src/main/java/org/apache/rocketmq/store/queue/SparseConsumeQueue.java x: 321 lines of code y: 4 # changes client/src/main/java/org/apache/rocketmq/client/trace/TraceConstants.java x: 25 lines of code y: 18 # changes client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionOpenTracingHookImpl.java x: 48 lines of code y: 6 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/ConsumerProcessor.java x: 499 lines of code y: 25 # changes broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java x: 128 lines of code y: 31 # changes common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolMonitor.java x: 101 lines of code y: 10 # changes proxy/src/main/resources/rmq.proxy.logback.xml x: 403 lines of code y: 9 # changes broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopRequest.java x: 73 lines of code y: 10 # changes broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsConstant.java x: 43 lines of code y: 7 # changes broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsManager.java x: 605 lines of code y: 24 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/FileRegionEncoder.java x: 37 lines of code y: 7 # changes example/src/main/java/org/apache/rocketmq/example/operation/Consumer.java x: 79 lines of code y: 8 # changes example/src/main/java/org/apache/rocketmq/example/benchmark/BatchProducer.java x: 360 lines of code y: 18 # changes example/src/main/java/org/apache/rocketmq/example/benchmark/Producer.java x: 369 lines of code y: 40 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java x: 485 lines of code y: 60 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java x: 235 lines of code y: 29 # changes client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java x: 254 lines of code y: 17 # changes client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java x: 29 lines of code y: 20 # changes auth/src/main/java/org/apache/rocketmq/auth/authentication/builder/DefaultAuthenticationContextBuilder.java x: 105 lines of code y: 2 # changes auth/src/main/java/org/apache/rocketmq/auth/authentication/manager/AuthenticationMetadataManagerImpl.java x: 189 lines of code y: 4 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SimpleSubscriptionData.java x: 62 lines of code y: 2 # changes auth/src/main/java/org/apache/rocketmq/auth/authentication/provider/DefaultAuthenticationProvider.java x: 56 lines of code y: 2 # changes common/src/main/java/org/apache/rocketmq/common/attribute/TopicMessageType.java x: 41 lines of code y: 10 # changes client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java x: 245 lines of code y: 44 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java x: 386 lines of code y: 51 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopOrderlyService.java x: 334 lines of code y: 14 # changes client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java x: 57 lines of code y: 22 # changes client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java x: 111 lines of code y: 16 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/ClusterMetadataService.java x: 237 lines of code y: 14 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteService.java x: 187 lines of code y: 23 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java x: 171 lines of code y: 5 # changes auth/src/main/java/org/apache/rocketmq/auth/authorization/manager/AuthorizationMetadataManagerImpl.java x: 238 lines of code y: 2 # changes auth/src/main/java/org/apache/rocketmq/auth/authentication/provider/LocalAuthenticationMetadataProvider.java x: 135 lines of code y: 2 # changes auth/src/main/java/org/apache/rocketmq/auth/authorization/provider/LocalAuthorizationMetadataProvider.java x: 167 lines of code y: 2 # changes auth/src/main/java/org/apache/rocketmq/auth/authorization/model/Resource.java x: 131 lines of code y: 1 # changes auth/src/main/java/org/apache/rocketmq/auth/config/AuthConfig.java x: 193 lines of code y: 1 # changes broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java x: 252 lines of code y: 51 # changes broker/src/main/java/org/apache/rocketmq/broker/auth/converter/AclConverter.java x: 96 lines of code y: 1 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java x: 81 lines of code y: 30 # changes broker/src/main/resources/rmq.broker.logback.xml x: 664 lines of code y: 13 # changes client/src/main/java/org/apache/rocketmq/client/MQAdmin.java x: 21 lines of code y: 15 # changes common/src/main/java/org/apache/rocketmq/common/Pair.java x: 25 lines of code y: 6 # changes common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java x: 40 lines of code y: 33 # changes container/src/main/java/org/apache/rocketmq/container/BrokerContainer.java x: 384 lines of code y: 20 # changes proxy/src/main/java/org/apache/rocketmq/proxy/config/Configuration.java x: 68 lines of code y: 16 # changes proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigurationManager.java x: 38 lines of code y: 8 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/ProxyAndTlsProtocolNegotiator.java x: 233 lines of code y: 6 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/ContextInterceptor.java x: 19 lines of code y: 6 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseBuilder.java x: 89 lines of code y: 13 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/transaction/EndTransactionActivity.java x: 57 lines of code y: 10 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionProcessor.java x: 55 lines of code y: 8 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannel.java x: 222 lines of code y: 7 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/Http2ProtocolProxyHandler.java x: 96 lines of code y: 7 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java x: 17 lines of code y: 8 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/MetadataService.java x: 14 lines of code y: 7 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/AbstractProxyRelayService.java x: 42 lines of code y: 6 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionData.java x: 85 lines of code y: 5 # changes remoting/src/main/java/org/apache/rocketmq/remoting/RemotingService.java x: 9 lines of code y: 8 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/NamespaceUtil.java x: 107 lines of code y: 2 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSerializable.java x: 55 lines of code y: 16 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/AclInfo.java x: 93 lines of code y: 1 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CloneGroupOffsetRequestHeader.java x: 57 lines of code y: 3 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ConsumeMessageDirectlyResultRequestHeader.java x: 87 lines of code y: 3 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CreateTopicRequestHeader.java x: 120 lines of code y: 3 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/DeleteSubscriptionGroupRequestHeader.java x: 31 lines of code y: 3 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/DeleteTopicRequestHeader.java x: 24 lines of code y: 3 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetAllProducerInfoRequestHeader.java x: 13 lines of code y: 2 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetMinOffsetRequestHeader.java x: 44 lines of code y: 2 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetProducerConnectionListRequestHeader.java x: 22 lines of code y: 3 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PopMessageRequestHeader.java x: 137 lines of code y: 3 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PullMessageRequestHeader.java x: 255 lines of code y: 2 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryConsumerOffsetRequestHeader.java x: 62 lines of code y: 3 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeaderV2.java x: 274 lines of code y: 4 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/AlterSyncStateSetRequestHeader.java x: 56 lines of code y: 5 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/ElectMasterRequestHeader.java x: 87 lines of code y: 7 # changes tools/src/main/java/org/apache/rocketmq/tools/command/auth/CreateAclSubCommand.java x: 105 lines of code y: 1 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java x: 1071 lines of code y: 74 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/AppendResult.java x: 8 lines of code y: 3 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/exception/TieredStoreException.java x: 36 lines of code y: 4 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/stream/CommitLogInputStream.java x: 151 lines of code y: 1 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/stream/FileSegmentInputStream.java x: 134 lines of code y: 1 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java x: 188 lines of code y: 46 # changes broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java x: 212 lines of code y: 18 # changes common/src/main/java/org/apache/rocketmq/common/namesrv/DefaultTopAddressing.java x: 128 lines of code y: 10 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ClusterTopicRouteService.java x: 32 lines of code y: 10 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/route/LocalTopicRouteService.java x: 65 lines of code y: 11 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java x: 297 lines of code y: 39 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java x: 180 lines of code y: 4 # changes client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java x: 235 lines of code y: 21 # changes broker/src/main/java/org/apache/rocketmq/broker/plugin/PullMessageResultHandler.java x: 22 lines of code y: 7 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/DefaultPullMessageResultHandler.java x: 246 lines of code y: 17 # changes common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java x: 218 lines of code y: 10 # changes controller/src/main/java/org/apache/rocketmq/controller/BrokerHeartbeatManager.java x: 29 lines of code y: 13 # changes controller/src/main/java/org/apache/rocketmq/controller/ControllerManager.java x: 306 lines of code y: 31 # changes controller/src/main/java/org/apache/rocketmq/controller/ControllerStartup.java x: 120 lines of code y: 11 # changes controller/src/main/java/org/apache/rocketmq/controller/elect/impl/DefaultElectPolicy.java x: 74 lines of code y: 7 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerControllerStateMachine.java x: 57 lines of code y: 12 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/JRaftControllerStateMachine.java x: 288 lines of code y: 1 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/event/ApplyBrokerIdEvent.java x: 45 lines of code y: 7 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/BrokerLiveInfo.java x: 113 lines of code y: 2 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/manager/BrokerReplicaInfo.java x: 79 lines of code y: 6 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/manager/RaftReplicasInfoManager.java x: 201 lines of code y: 1 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManager.java x: 568 lines of code y: 37 # changes controller/src/main/java/org/apache/rocketmq/controller/metrics/ControllerMetricsManager.java x: 311 lines of code y: 4 # changes controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java x: 294 lines of code y: 29 # changes controller/src/main/resources/rmq.controller.logback.xml x: 152 lines of code y: 9 # changes example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java x: 31 lines of code y: 22 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java x: 566 lines of code y: 59 # changes client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java x: 25 lines of code y: 22 # changes proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java x: 13 lines of code y: 12 # changes proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java x: 97 lines of code y: 11 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolRemotingServer.java x: 58 lines of code y: 7 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageService.java x: 18 lines of code y: 11 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/DefaultTransactionalMessageCheckListener.java x: 58 lines of code y: 15 # changes remoting/src/main/java/org/apache/rocketmq/remoting/metrics/RemotingMetricsConstant.java x: 15 lines of code y: 4 # changes store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsManager.java x: 216 lines of code y: 6 # changes broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingCleanService.java x: 297 lines of code y: 13 # changes client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java x: 206 lines of code y: 40 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java x: 319 lines of code y: 43 # changes example/src/main/java/org/apache/rocketmq/example/benchmark/TransactionProducer.java x: 399 lines of code y: 35 # changes example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java x: 21 lines of code y: 13 # changes example/src/main/java/org/apache/rocketmq/example/tracemessage/TraceProducer.java x: 33 lines of code y: 14 # changes example/src/main/java/org/apache/rocketmq/example/tracemessage/TracePushConsumer.java x: 23 lines of code y: 15 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManager.java x: 204 lines of code y: 21 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java x: 194 lines of code y: 17 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity.java x: 162 lines of code y: 28 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageResponseStreamWriter.java x: 131 lines of code y: 10 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/ForwardMessageToDLQActivity.java x: 49 lines of code y: 13 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/ReceiptHandleProcessor.java x: 44 lines of code y: 31 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyChannel.java x: 155 lines of code y: 16 # changes common/src/main/java/org/apache/rocketmq/common/consumer/ReceiptHandle.java x: 184 lines of code y: 9 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ExtraInfoUtil.java x: 261 lines of code y: 4 # changes store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java x: 739 lines of code y: 46 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageAccessor.java x: 68 lines of code y: 7 # changes common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java x: 159 lines of code y: 18 # changes broker/src/main/java/org/apache/rocketmq/broker/filter/ExpressionForRetryMessageFilter.java x: 59 lines of code y: 6 # changes tools/src/main/java/org/apache/rocketmq/tools/monitor/MonitorService.java x: 261 lines of code y: 20 # changes example/src/main/java/org/apache/rocketmq/example/transaction/TransactionProducer.java x: 48 lines of code y: 14 # changes store/src/main/java/org/apache/rocketmq/store/RunningFlags.java x: 110 lines of code y: 10 # changes client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java x: 16 lines of code y: 6 # changes store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueInterface.java x: 35 lines of code y: 14 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageConst.java x: 123 lines of code y: 37 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java x: 65 lines of code y: 23 # changes container/src/main/java/org/apache/rocketmq/container/ContainerClientHouseKeepingService.java x: 72 lines of code y: 6 # changes controller/src/main/java/org/apache/rocketmq/controller/BrokerHousekeepingService.java x: 31 lines of code y: 7 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java x: 28 lines of code y: 11 # changes common/src/main/java/org/apache/rocketmq/common/attribute/CQType.java x: 6 lines of code y: 6 # changes common/src/main/java/org/apache/rocketmq/common/topic/TopicValidator.java x: 106 lines of code y: 13 # changes store/src/main/java/org/apache/rocketmq/store/CommitLogDispatcher.java x: 5 lines of code y: 4 # changes store/src/main/java/org/apache/rocketmq/store/ha/HAService.java x: 39 lines of code y: 52 # changes store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAClient.java x: 443 lines of code y: 26 # changes store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java x: 456 lines of code y: 44 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncer.java x: 203 lines of code y: 9 # changes remoting/src/main/java/org/apache/rocketmq/remoting/RemotingClient.java x: 53 lines of code y: 19 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/ResponseFuture.java x: 125 lines of code y: 11 # changes store/src/main/java/org/apache/rocketmq/store/timer/TimerRequest.java x: 88 lines of code y: 6 # changes proxy/src/main/java/org/apache/rocketmq/proxy/metrics/ProxyMetricsManager.java x: 215 lines of code y: 11 # changes broker/src/main/java/org/apache/rocketmq/broker/dledger/DLedgerRoleChangeHandler.java x: 145 lines of code y: 22 # changes common/src/main/java/org/apache/rocketmq/common/utils/ThreadUtils.java x: 139 lines of code y: 12 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java x: 216 lines of code y: 33 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java x: 95 lines of code y: 13 # changes store/src/main/java/org/apache/rocketmq/store/kv/CompactionStore.java x: 195 lines of code y: 11 # changes client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultTolerance.java x: 16 lines of code y: 5 # changes client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java x: 131 lines of code y: 24 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueView.java x: 41 lines of code y: 8 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueSelector.java x: 253 lines of code y: 11 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/AbstractProcessor.java x: 21 lines of code y: 10 # changes store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java x: 89 lines of code y: 12 # changes tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java x: 128 lines of code y: 13 # changes tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java x: 101 lines of code y: 16 # changes tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerEpochSubCommand.java x: 94 lines of code y: 4 # changes tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java x: 82 lines of code y: 9 # changes tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java x: 158 lines of code y: 26 # changes tools/src/main/java/org/apache/rocketmq/tools/command/connection/ProducerConnectionSubCommand.java x: 59 lines of code y: 8 # changes tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java x: 121 lines of code y: 16 # changes tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java x: 118 lines of code y: 14 # changes tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java x: 161 lines of code y: 14 # changes tools/src/main/java/org/apache/rocketmq/tools/command/controller/ReElectMasterSubCommand.java x: 64 lines of code y: 8 # changes tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java x: 134 lines of code y: 7 # changes tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetricsCommand.java x: 207 lines of code y: 11 # changes tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java x: 111 lines of code y: 8 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java x: 104 lines of code y: 14 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java x: 243 lines of code y: 9 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageByQueueCommand.java x: 199 lines of code y: 12 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java x: 155 lines of code y: 18 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java x: 129 lines of code y: 14 # changes tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/AddWritePermSubCommand.java x: 58 lines of code y: 4 # changes tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java x: 81 lines of code y: 13 # changes tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicPermSubCommand.java x: 135 lines of code y: 23 # changes tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java x: 147 lines of code y: 26 # changes store/src/main/java/org/apache/rocketmq/store/TransientStorePool.java x: 60 lines of code y: 14 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java x: 193 lines of code y: 19 # changes example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java x: 22 lines of code y: 18 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator/TopicMessageTypeValidator.java x: 5 lines of code y: 5 # changes proxy/src/main/java/org/apache/rocketmq/proxy/common/RenewEvent.java x: 38 lines of code y: 3 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/Http2ProxyBackendHandler.java x: 43 lines of code y: 4 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageBatch.java x: 48 lines of code y: 10 # changes store/src/main/java/org/apache/rocketmq/store/timer/Slot.java x: 23 lines of code y: 5 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/ClientProcessor.java x: 87 lines of code y: 9 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java x: 142 lines of code y: 5 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelManager.java x: 99 lines of code y: 5 # changes proxy/src/main/java/org/apache/rocketmq/proxy/common/MessageReceiptHandle.java x: 115 lines of code y: 10 # changes client/src/main/java/org/apache/rocketmq/client/hook/ConsumeMessageContext.java x: 71 lines of code y: 9 # changes client/src/main/java/org/apache/rocketmq/client/trace/TraceContext.java x: 100 lines of code y: 12 # changes client/src/main/java/org/apache/rocketmq/client/trace/hook/ConsumeMessageTraceHookImpl.java x: 89 lines of code y: 17 # changes filter/src/main/java/org/apache/rocketmq/filter/expression/ComparisonExpression.java x: 494 lines of code y: 9 # changes filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParserTokenManager.java x: 973 lines of code y: 5 # changes common/src/main/java/org/apache/rocketmq/common/BrokerIdentity.java x: 104 lines of code y: 11 # changes filter/src/main/java/org/apache/rocketmq/filter/parser/SimpleCharStream.java x: 304 lines of code y: 11 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java x: 237 lines of code y: 27 # changes common/src/main/java/org/apache/rocketmq/common/PopAckConstants.java x: 21 lines of code y: 9 # changes store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java x: 54 lines of code y: 21 # changes store/src/main/java/org/apache/rocketmq/store/util/LibC.java x: 27 lines of code y: 4 # changes store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java x: 128 lines of code y: 21 # changes example/src/main/java/org/apache/rocketmq/example/benchmark/Consumer.java x: 235 lines of code y: 40 # changes client/src/main/java/org/apache/rocketmq/client/Validators.java x: 92 lines of code y: 26 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionDataManager.java x: 130 lines of code y: 9 # changes store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java x: 558 lines of code y: 30 # changes client/src/main/java/org/apache/rocketmq/client/impl/admin/MqClientAdminImpl.java x: 395 lines of code y: 1 # changes namesrv/src/main/resources/rmq.namesrv.logback.xml x: 90 lines of code y: 5 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java x: 144 lines of code y: 21 # changes store/src/main/java/org/apache/rocketmq/store/AppendMessageCallback.java x: 10 lines of code y: 16 # changes store/src/main/java/org/apache/rocketmq/store/kv/CompactionLog.java x: 940 lines of code y: 7 # changes example/src/main/java/org/apache/rocketmq/example/simple/PushConsumer.java x: 29 lines of code y: 16 # changes controller/src/main/java/org/apache/rocketmq/controller/Controller.java x: 33 lines of code y: 17 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageUtil.java x: 63 lines of code y: 15 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BrokerReplicasInfo.java x: 148 lines of code y: 5 # changes store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java x: 186 lines of code y: 27 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/RoleChangeNotifyEntry.java x: 50 lines of code y: 4 # changes controller/src/main/java/org/apache/rocketmq/controller/helper/BrokerLiveInfoGetter.java x: 5 lines of code y: 2 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/event/EventType.java x: 38 lines of code y: 6 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageType.java x: 23 lines of code y: 8 # changes store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAClient.java x: 312 lines of code y: 14 # changes store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAConnection.java x: 363 lines of code y: 16 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/AssignedMessageQueue.java x: 193 lines of code y: 24 # changes remoting/src/main/java/org/apache/rocketmq/remoting/common/ServiceThread.java x: 49 lines of code y: 16 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyDecoder.java x: 40 lines of code y: 17 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/BrokerData.java x: 121 lines of code y: 2 # changes store/src/main/java/org/apache/rocketmq/store/stats/BrokerStats.java x: 56 lines of code y: 20 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java x: 121 lines of code y: 18 # changes style/rmq_checkstyle.xml x: 88 lines of code y: 8 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java x: 310 lines of code y: 29 # changes tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminUtils.java x: 291 lines of code y: 6 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RocketMQSerializable.java x: 171 lines of code y: 13 # changes client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java x: 43 lines of code y: 21 # changes distribution/release.xml x: 92 lines of code y: 27 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerData.java x: 130 lines of code y: 4 # changes store/src/main/java/org/apache/rocketmq/store/pop/AckMsg.java x: 73 lines of code y: 8 # changes example/src/main/java/org/apache/rocketmq/example/simple/LitePullConsumerAssign.java x: 32 lines of code y: 8 # changes tools/src/main/java/org/apache/rocketmq/tools/admin/common/AdminToolsResultCodeEnum.java x: 18 lines of code y: 5 # changes broker/src/main/java/org/apache/rocketmq/broker/BrokerPreOnlineService.java x: 233 lines of code y: 10 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageCheckService.java x: 38 lines of code y: 20 # changes common/src/main/java/org/apache/rocketmq/common/ThreadFactoryImpl.java x: 39 lines of code y: 15 # changes container/src/main/java/org/apache/rocketmq/container/BrokerContainerStartup.java x: 343 lines of code y: 16 # changes store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java x: 536 lines of code y: 34 # changes broker/src/main/java/org/apache/rocketmq/broker/filter/ConsumerFilterManager.java x: 354 lines of code y: 16 # changes broker/src/main/java/org/apache/rocketmq/broker/filter/ExpressionMessageFilter.java x: 113 lines of code y: 9 # changes broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java x: 146 lines of code y: 4 # changes client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java x: 162 lines of code y: 22 # changes client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java x: 25 lines of code y: 19 # changes client/src/main/java/org/apache/rocketmq/client/producer/RequestFutureHolder.java x: 77 lines of code y: 9 # changes common/src/main/java/org/apache/rocketmq/common/queue/ConcurrentTreeMap.java x: 46 lines of code y: 9 # changes common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemPrinter.java x: 25 lines of code y: 7 # changes example/src/main/java/org/apache/rocketmq/example/benchmark/timer/TimerProducer.java x: 249 lines of code y: 8 # changes example/src/main/java/org/apache/rocketmq/example/rpc/AsyncRequestProducer.java x: 37 lines of code y: 9 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java x: 157 lines of code y: 21 # changes openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/PullConsumerImpl.java x: 145 lines of code y: 16 # changes openmessaging/src/main/java/io/openmessaging/rocketmq/producer/AbstractOMSProducer.java x: 111 lines of code y: 12 # changes openmessaging/src/main/java/io/openmessaging/rocketmq/producer/ProducerImpl.java x: 112 lines of code y: 7 # changes openmessaging/src/main/java/io/openmessaging/rocketmq/utils/BeanUtils.java x: 126 lines of code y: 16 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/AbstractMessingActivity.java x: 36 lines of code y: 13 # changes remoting/src/main/java/org/apache/rocketmq/remoting/Configuration.java x: 243 lines of code y: 4 # changes srvutil/src/main/java/org/apache/rocketmq/srvutil/ShutdownHookThread.java x: 32 lines of code y: 6 # changes store/src/main/java/org/apache/rocketmq/store/StoreUtil.java x: 52 lines of code y: 11 # changes store/src/main/java/org/apache/rocketmq/store/ha/WaitNotifyObject.java x: 85 lines of code y: 24 # changes store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/EpochFileCache.java x: 264 lines of code y: 8 # changes store/src/main/java/org/apache/rocketmq/store/timer/TimerCheckpoint.java x: 141 lines of code y: 9 # changes tools/src/main/java/org/apache/rocketmq/tools/monitor/DefaultMonitorListener.java x: 59 lines of code y: 9 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageService.java x: 23 lines of code y: 14 # changes client/src/main/java/org/apache/rocketmq/client/impl/producer/MQProducerInner.java x: 18 lines of code y: 14 # changes client/src/main/java/org/apache/rocketmq/client/trace/hook/ConsumeMessageOpenTracingHookImpl.java x: 69 lines of code y: 11 # changes common/src/main/java/org/apache/rocketmq/common/utils/IOTinyUtils.java x: 123 lines of code y: 7 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumerRunningInfo.java x: 273 lines of code y: 1 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PullMessageResponseHeader.java x: 123 lines of code y: 1 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/TopicRouteData.java x: 175 lines of code y: 1 # changes dev/merge_rocketmq_pr.py x: 298 lines of code y: 5 # changes store/src/main/java/org/apache/rocketmq/store/AppendMessageResult.java x: 120 lines of code y: 13 # changes example/src/main/java/org/apache/rocketmq/example/operation/Producer.java x: 78 lines of code y: 6 # changes client/src/main/java/org/apache/rocketmq/client/trace/TraceView.java x: 131 lines of code y: 8 # changes filter/src/main/java/org/apache/rocketmq/filter/expression/UnaryExpression.java x: 192 lines of code y: 7 # changes example/src/main/java/org/apache/rocketmq/example/batch/SimpleBatchProducer.java x: 23 lines of code y: 10 # changes example/src/main/java/org/apache/rocketmq/example/openmessaging/SimpleProducer.java x: 50 lines of code y: 11 # changes tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java x: 51 lines of code y: 6 # changes client/src/main/java/org/apache/rocketmq/client/trace/TraceDispatcher.java x: 14 lines of code y: 17 # changes store/src/main/java/org/apache/rocketmq/store/queue/ReferredIterator.java x: 6 lines of code y: 5 # changes style/rmq_codeStyle.xml x: 126 lines of code y: 4 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java x: 5 lines of code y: 8 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ProducerGroupEvent.java x: 5 lines of code y: 3 # changes broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java x: 26 lines of code y: 9 # changes broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java x: 230 lines of code y: 12 # changes broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java x: 68 lines of code y: 14 # changes client/src/main/java/org/apache/rocketmq/client/consumer/AckCallback.java x: 5 lines of code y: 6 # changes client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java x: 37 lines of code y: 11 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopRequest.java x: 93 lines of code y: 6 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java x: 78 lines of code y: 12 # changes common/src/main/java/org/apache/rocketmq/common/TopicConfig.java x: 207 lines of code y: 15 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java x: 217 lines of code y: 20 # changes common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java x: 5 lines of code y: 11 # changes common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItem.java x: 108 lines of code y: 4 # changes proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyExceptionCode.java x: 9 lines of code y: 9 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannelHandlerContext.java x: 184 lines of code y: 3 # changes store/src/main/java/org/apache/rocketmq/store/ha/HAConnection.java x: 13 lines of code y: 26 # changes example/src/main/java/org/apache/rocketmq/example/rpc/RequestProducer.java x: 27 lines of code y: 12 # changes filter/src/main/java/org/apache/rocketmq/filter/util/BloomFilter.java x: 156 lines of code y: 8 # changes tools/src/main/java/org/apache/rocketmq/tools/command/SubCommand.java x: 13 lines of code y: 8 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/DledgerController.java x: 479 lines of code y: 3 # changes example/src/main/java/org/apache/rocketmq/example/ordermessage/Consumer.java x: 35 lines of code y: 12 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettySystemConfig.java x: 51 lines of code y: 20 # changes broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java x: 79 lines of code y: 10 # changes common/src/main/java/org/apache/rocketmq/common/utils/NameServerAddressUtils.java x: 29 lines of code y: 15 # changes client/src/main/java/org/apache/rocketmq/client/utils/MessageUtil.java x: 34 lines of code y: 10 # changes openmessaging/src/main/java/io/openmessaging/rocketmq/domain/BytesMessageImpl.java x: 80 lines of code y: 5 # changes broker/src/main/java/org/apache/rocketmq/broker/filter/ConsumerFilterData.java x: 97 lines of code y: 3 # changes filter/src/main/java/org/apache/rocketmq/filter/util/BitsArray.java x: 186 lines of code y: 1 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java x: 70 lines of code y: 3 # changes
198.0
# changes
  min: 1.0
  average: 9.4
  25th percentile: 1.0
  median: 4.0
  75th percentile: 10.0
  max: 198.0
0 3092.0
lines of code
min: 1.0 | average: 113.96 | 25th percentile: 22.0 | median: 47.0 | 75th percentile: 111.25 | max: 3092.0

Number of Contributors vs. Number of Changes: 1490 points

common/src/main/java/org/apache/rocketmq/common/MQVersion.java x: 26 # contributors y: 61 # changes broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java x: 3 # contributors y: 4 # changes broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java x: 12 # contributors y: 18 # changes broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java x: 2 # contributors y: 3 # changes broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java x: 3 # contributors y: 7 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java x: 18 # contributors y: 31 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java x: 87 # contributors y: 157 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java x: 19 # contributors y: 26 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java x: 20 # contributors y: 30 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java x: 34 # contributors y: 74 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java x: 26 # contributors y: 47 # changes broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java x: 9 # contributors y: 12 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java x: 3 # contributors y: 3 # changes store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java x: 11 # contributors y: 15 # changes broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java x: 5 # contributors y: 5 # changes broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java x: 6 # contributors y: 6 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java x: 2 # contributors y: 6 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java x: 3 # contributors y: 8 # changes client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java x: 50 # contributors y: 61 # changes auth/src/main/java/org/apache/rocketmq/auth/migration/AuthMigrator.java x: 1 # contributors y: 3 # changes auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AccessResource.java x: 1 # contributors y: 1 # changes broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java x: 87 # contributors y: 188 # changes client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java x: 85 # contributors y: 152 # changes common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java x: 63 # contributors y: 141 # changes proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java x: 16 # contributors y: 35 # changes proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java x: 23 # contributors y: 60 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java x: 17 # contributors y: 23 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java x: 10 # contributors y: 14 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/AuthenticationPipeline.java x: 4 # contributors y: 5 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java x: 17 # contributors y: 19 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/ResponseCode.java x: 8 # contributors y: 9 # changes tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java x: 54 # contributors y: 88 # changes tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java x: 64 # contributors y: 111 # changes tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java x: 48 # contributors y: 79 # changes tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java x: 53 # contributors y: 94 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java x: 1 # contributors y: 4 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java x: 4 # contributors y: 7 # changes broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java x: 20 # contributors y: 32 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java x: 20 # contributors y: 31 # changes store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java x: 99 # contributors y: 198 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java x: 6 # contributors y: 8 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java x: 27 # contributors y: 38 # changes client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java x: 72 # contributors y: 114 # changes broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java x: 14 # contributors y: 18 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java x: 4 # contributors y: 10 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsHelper.java x: 12 # contributors y: 14 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java x: 37 # contributors y: 55 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java x: 13 # contributors y: 22 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/TopicStatsTable.java x: 2 # contributors y: 2 # changes store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java x: 24 # contributors y: 40 # changes tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java x: 7 # contributors y: 11 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java x: 14 # contributors y: 31 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java x: 37 # contributors y: 59 # changes broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java x: 21 # contributors y: 32 # changes common/src/main/java/org/apache/rocketmq/common/MixAll.java x: 66 # contributors y: 96 # changes broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java x: 12 # contributors y: 13 # changes store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java x: 12 # contributors y: 17 # changes common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItem.java x: 11 # contributors y: 14 # changes common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java x: 21 # contributors y: 23 # changes common/src/main/java/org/apache/rocketmq/common/stats/StatsItem.java x: 19 # contributors y: 20 # changes common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java x: 24 # contributors y: 27 # changes store/src/main/java/org/apache/rocketmq/store/CommitLog.java x: 83 # contributors y: 135 # changes store/src/main/java/org/apache/rocketmq/store/index/IndexService.java x: 15 # contributors y: 23 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java x: 14 # contributors y: 19 # changes store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java x: 50 # contributors y: 71 # changes store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueStore.java x: 6 # contributors y: 10 # changes broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java x: 23 # contributors y: 28 # changes broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerContext.java x: 1 # contributors y: 2 # changes client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java x: 87 # contributors y: 132 # changes client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java x: 61 # contributors y: 97 # changes store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java x: 25 # contributors y: 36 # changes broker/src/main/java/org/apache/rocketmq/broker/BrokerPathConfigHelper.java x: 12 # contributors y: 21 # changes broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerLagCalculator.java x: 8 # contributors y: 15 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java x: 15 # contributors y: 26 # changes client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java x: 7 # contributors y: 10 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java x: 6 # contributors y: 21 # changes broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java x: 24 # contributors y: 34 # changes broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java x: 42 # contributors y: 68 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java x: 60 # contributors y: 100 # changes client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIFactory.java x: 4 # contributors y: 4 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java x: 16 # contributors y: 21 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManagerFactory.java x: 6 # contributors y: 4 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java x: 46 # contributors y: 73 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java x: 43 # contributors y: 73 # changes filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParser.java x: 10 # contributors y: 11 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java x: 10 # contributors y: 16 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/AckMessageActivity.java x: 9 # contributors y: 17 # changes common/src/main/java/org/apache/rocketmq/common/config/AbstractRocksDBStorage.java x: 9 # contributors y: 13 # changes tools/src/main/java/org/apache/rocketmq/tools/command/metadata/RocksDBConfigToJsonCommand.java x: 5 # contributors y: 6 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java x: 31 # contributors y: 44 # changes broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopLongPollingService.java x: 4 # contributors y: 6 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/ProducerProcessor.java x: 15 # contributors y: 22 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreDispatcherImpl.java x: 3 # contributors y: 5 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java x: 34 # contributors y: 48 # changes auth/src/main/java/org/apache/rocketmq/auth/authorization/builder/DefaultAuthorizationContextBuilder.java x: 3 # contributors y: 6 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java x: 56 # contributors y: 87 # changes broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java x: 16 # contributors y: 23 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java x: 21 # contributors y: 30 # changes store/src/main/java/org/apache/rocketmq/store/MessageStore.java x: 35 # contributors y: 55 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java x: 59 # contributors y: 97 # changes client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java x: 16 # contributors y: 22 # changes client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java x: 22 # contributors y: 27 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/RequestMapping.java x: 7 # contributors y: 5 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/DefaultGrpcMessingActivity.java x: 11 # contributors y: 22 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java x: 14 # contributors y: 22 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessingActivity.java x: 8 # contributors y: 8 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java x: 12 # contributors y: 24 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java x: 16 # contributors y: 32 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/MessagingProcessor.java x: 13 # contributors y: 26 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalMessageService.java x: 16 # contributors y: 26 # changes srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java x: 16 # contributors y: 20 # changes store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java x: 64 # contributors y: 102 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java x: 28 # contributors y: 38 # changes client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java x: 7 # contributors y: 7 # changes client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageTraceHookImpl.java x: 17 # contributors y: 21 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java x: 41 # contributors y: 58 # changes container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java x: 14 # contributors y: 16 # changes client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java x: 31 # contributors y: 45 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java x: 47 # contributors y: 62 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatFileStore.java x: 2 # contributors y: 4 # changes proxy/src/main/java/org/apache/rocketmq/proxy/common/Address.java x: 6 # contributors y: 5 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ProxyTopicRouteData.java x: 9 # contributors y: 8 # changes proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroup.java x: 9 # contributors y: 11 # changes broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotifyMessageArrivingListener.java x: 9 # contributors y: 16 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java x: 28 # contributors y: 43 # changes common/src/main/java/org/apache/rocketmq/common/constant/PermName.java x: 11 # contributors y: 17 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java x: 21 # contributors y: 25 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java x: 51 # contributors y: 82 # changes remoting/src/main/java/org/apache/rocketmq/remoting/protocol/LanguageCode.java x: 8 # contributors y: 11 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyLogger.java x: 10 # contributors y: 10 # changes broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java x: 8 # contributors y: 12 # changes broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java x: 16 # contributors y: 27 # changes common/src/main/java/org/apache/rocketmq/common/ServiceThread.java x: 19 # contributors y: 27 # changes store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java x: 46 # contributors y: 72 # changes store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java x: 13 # contributors y: 17 # changes store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java x: 17 # contributors y: 22 # changes tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metrics/TieredStoreMetricsManager.java x: 5 # contributors y: 10 # changes store/src/main/java/org/apache/rocketmq/store/timer/TimerLog.java x: 7 # contributors y: 8 # changes broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java x: 14 # contributors y: 20 # changes broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java x: 20 # contributors y: 51 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java x: 23 # contributors y: 33 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/HeaderInterceptor.java x: 8 # contributors y: 10 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java x: 10 # contributors y: 15 # changes client/src/main/java/org/apache/rocketmq/client/consumer/PopStatus.java x: 5 # contributors y: 7 # changes common/src/main/java/org/apache/rocketmq/common/utils/ServiceProvider.java x: 9 # contributors y: 14 # changes openmessaging/src/main/java/io/openmessaging/rocketmq/promise/DefaultPromise.java x: 7 # contributors y: 12 # changes store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java x: 23 # contributors y: 32 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java x: 19 # contributors y: 36 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/HAProxyMessageForwarder.java x: 2 # contributors y: 5 # changes client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java x: 37 # contributors y: 72 # changes tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java x: 23 # contributors y: 34 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java x: 21 # contributors y: 28 # changes tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommand.java x: 18 # contributors y: 23 # changes common/src/main/java/org/apache/rocketmq/common/ConfigManager.java x: 13 # contributors y: 18 # changes common/src/main/java/org/apache/rocketmq/common/UtilAll.java x: 51 # contributors y: 73 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ClientManagerActivity.java x: 6 # contributors y: 7 # changes broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java x: 46 # contributors y: 85 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java x: 13 # contributors y: 16 # changes client/src/main/java/org/apache/rocketmq/client/ClientConfig.java x: 41 # contributors y: 61 # changes client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java x: 30 # contributors y: 47 # changes proxy/src/main/java/org/apache/rocketmq/proxy/processor/ConsumerProcessor.java x: 13 # contributors y: 25 # changes broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java x: 19 # contributors y: 31 # changes proxy/src/main/resources/rmq.proxy.logback.xml x: 7 # contributors y: 9 # changes broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsManager.java x: 11 # contributors y: 24 # changes example/src/main/java/org/apache/rocketmq/example/operation/Consumer.java x: 5 # contributors y: 8 # changes example/src/main/java/org/apache/rocketmq/example/benchmark/BatchProducer.java x: 17 # contributors y: 18 # changes example/src/main/java/org/apache/rocketmq/example/benchmark/Producer.java x: 27 # contributors y: 40 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java x: 41 # contributors y: 60 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java x: 21 # contributors y: 29 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java x: 19 # contributors y: 25 # changes client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java x: 13 # contributors y: 20 # changes client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java x: 30 # contributors y: 44 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java x: 36 # contributors y: 51 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/ClusterMetadataService.java x: 13 # contributors y: 14 # changes broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java x: 31 # contributors y: 51 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java x: 25 # contributors y: 30 # changes broker/src/main/resources/rmq.broker.logback.xml x: 8 # contributors y: 13 # changes client/src/main/java/org/apache/rocketmq/client/MQAdmin.java x: 12 # contributors y: 15 # changes common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java x: 27 # contributors y: 33 # changes proxy/src/main/java/org/apache/rocketmq/proxy/config/Configuration.java x: 12 # contributors y: 16 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/ProxyAndTlsProtocolNegotiator.java x: 1 # contributors y: 6 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/ContextInterceptor.java x: 7 # contributors y: 6 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseBuilder.java x: 10 # contributors y: 13 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/LocalMetadataService.java x: 9 # contributors y: 7 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/AbstractProxyRelayService.java x: 8 # contributors y: 6 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java x: 48 # contributors y: 74 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java x: 30 # contributors y: 46 # changes broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java x: 11 # contributors y: 18 # changes common/src/main/java/org/apache/rocketmq/common/namesrv/DefaultTopAddressing.java x: 9 # contributors y: 10 # changes broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java x: 26 # contributors y: 39 # changes client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java x: 14 # contributors y: 21 # changes common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java x: 11 # contributors y: 10 # changes controller/src/main/java/org/apache/rocketmq/controller/ControllerManager.java x: 16 # contributors y: 31 # changes controller/src/main/java/org/apache/rocketmq/controller/ControllerStartup.java x: 11 # contributors y: 11 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerControllerStateMachine.java x: 11 # contributors y: 12 # changes controller/src/main/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManager.java x: 15 # contributors y: 37 # changes controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java x: 15 # contributors y: 29 # changes controller/src/main/resources/rmq.controller.logback.xml x: 6 # contributors y: 9 # changes example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java x: 19 # contributors y: 22 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java x: 35 # contributors y: 59 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/DefaultTransactionalMessageCheckListener.java x: 14 # contributors y: 15 # changes client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java x: 23 # contributors y: 40 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java x: 31 # contributors y: 43 # changes client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java x: 21 # contributors y: 27 # changes example/src/main/java/org/apache/rocketmq/example/benchmark/TransactionProducer.java x: 26 # contributors y: 35 # changes example/src/main/java/org/apache/rocketmq/example/namespace/ProducerWithNamespace.java x: 13 # contributors y: 13 # changes example/src/main/java/org/apache/rocketmq/example/tracemessage/TracePushConsumer.java x: 9 # contributors y: 15 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManager.java x: 13 # contributors y: 21 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcValidator.java x: 9 # contributors y: 9 # changes proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity.java x: 12 # contributors y: 28 # changes store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java x: 29 # contributors y: 46 # changes tools/src/main/java/org/apache/rocketmq/tools/monitor/MonitorService.java x: 12 # contributors y: 20 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageConst.java x: 29 # contributors y: 37 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java x: 13 # contributors y: 23 # changes controller/src/main/java/org/apache/rocketmq/controller/BrokerHousekeepingService.java x: 8 # contributors y: 7 # changes common/src/main/java/org/apache/rocketmq/common/topic/TopicValidator.java x: 11 # contributors y: 13 # changes store/src/main/java/org/apache/rocketmq/store/ha/HAService.java x: 37 # contributors y: 52 # changes store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java x: 20 # contributors y: 44 # changes proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncer.java x: 5 # contributors y: 9 # changes remoting/src/main/java/org/apache/rocketmq/remoting/RemotingClient.java x: 11 # contributors y: 19 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java x: 16 # contributors y: 33 # changes client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java x: 19 # contributors y: 24 # changes tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java x: 22 # contributors y: 26 # changes tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java x: 4 # contributors y: 8 # changes tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java x: 17 # contributors y: 26 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java x: 15 # contributors y: 19 # changes client/src/main/java/org/apache/rocketmq/client/trace/hook/ConsumeMessageTraceHookImpl.java x: 14 # contributors y: 17 # changes store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java x: 20 # contributors y: 21 # changes example/src/main/java/org/apache/rocketmq/example/benchmark/Consumer.java x: 28 # contributors y: 40 # changes store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java x: 14 # contributors y: 30 # changes store/src/main/java/org/apache/rocketmq/store/AppendMessageCallback.java x: 11 # contributors y: 16 # changes proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/remoting/RemotingProtocolHandler.java x: 3 # contributors y: 2 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageUtil.java x: 13 # contributors y: 15 # changes client/src/main/java/org/apache/rocketmq/client/impl/consumer/AssignedMessageQueue.java x: 16 # contributors y: 24 # changes store/src/main/java/org/apache/rocketmq/store/stats/BrokerStats.java x: 11 # contributors y: 20 # changes common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java x: 16 # contributors y: 18 # changes broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java x: 19 # contributors y: 29 # changes client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java x: 18 # contributors y: 21 # changes broker/src/main/java/org/apache/rocketmq/broker/util/HookUtils.java x: 15 # contributors y: 17 # changes store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java x: 21 # contributors y: 34 # changes client/src/main/java/org/apache/rocketmq/client/MQHelper.java x: 8 # contributors y: 14 # changes client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java x: 12 # contributors y: 19 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java x: 15 # contributors y: 21 # changes namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClusterTestRequestProcessor.java x: 10 # contributors y: 19 # changes client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionTraceHookImpl.java x: 14 # contributors y: 14 # changes example/src/main/java/org/apache/rocketmq/example/broadcast/PushConsumer.java x: 16 # contributors y: 19 # changes example/src/main/java/org/apache/rocketmq/example/openmessaging/SimplePullConsumer.java x: 10 # contributors y: 9 # changes proxy/src/main/java/org/apache/rocketmq/proxy/config/MetricCollectorMode.java x: 7 # contributors y: 4 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ProducerChangeListener.java x: 5 # contributors y: 4 # changes broker/src/main/java/org/apache/rocketmq/broker/client/ProducerGroupEvent.java x: 5 # contributors y: 3 # changes common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java x: 20 # contributors y: 22 # changes proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigFile.java x: 6 # contributors y: 3 # changes remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettySystemConfig.java x: 15 # contributors y: 20 # changes common/src/main/java/org/apache/rocketmq/common/utils/NameServerAddressUtils.java x: 15 # contributors y: 15 # changes client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java x: 1 # contributors y: 5 # changes
198.0
# changes
  min: 1.0
  average: 9.4
  25th percentile: 1.0
  median: 4.0
  75th percentile: 10.0
  max: 198.0
0 99.0
# contributors
min: 1.0 | average: 6.66 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 8.0 | max: 99.0

Number of Contributors vs. File Size: 1490 points

common/src/main/java/org/apache/rocketmq/common/MQVersion.java x: 26 # contributors y: 633 lines of code broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java x: 3 # contributors y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java x: 12 # contributors y: 484 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java x: 2 # contributors y: 146 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java x: 3 # contributors y: 599 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java x: 18 # contributors y: 416 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java x: 87 # contributors y: 2976 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java x: 19 # contributors y: 307 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java x: 20 # contributors y: 769 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java x: 34 # contributors y: 943 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java x: 9 # contributors y: 204 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java x: 3 # contributors y: 207 lines of code store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java x: 11 # contributors y: 148 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java x: 5 # contributors y: 132 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java x: 6 # contributors y: 208 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java x: 2 # contributors y: 227 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java x: 3 # contributors y: 367 lines of code client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java x: 50 # contributors y: 351 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/AuthMigrator.java x: 1 # contributors y: 191 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AccessResource.java x: 1 # contributors y: 3 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AclConfig.java x: 1 # contributors y: 25 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessConfig.java x: 1 # contributors y: 86 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessData.java x: 1 # contributors y: 68 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessResource.java x: 1 # contributors y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java x: 87 # contributors y: 2119 lines of code client/src/main/java/org/apache/rocketmq/acl/common/AclException.java x: 1 # contributors y: 39 lines of code client/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java x: 1 # contributors y: 229 lines of code client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java x: 1 # contributors y: 122 lines of code client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java x: 85 # contributors y: 3092 lines of code common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java x: 63 # contributors y: 1424 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java x: 16 # contributors y: 194 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java x: 23 # contributors y: 1136 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java x: 17 # contributors y: 77 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java x: 10 # contributors y: 320 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/AuthenticationPipeline.java x: 4 # contributors y: 40 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java x: 17 # contributors y: 161 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/ResponseCode.java x: 8 # contributors y: 64 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java x: 54 # contributors y: 820 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java x: 64 # contributors y: 1791 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java x: 48 # contributors y: 322 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java x: 53 # contributors y: 280 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java x: 1 # contributors y: 53 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java x: 4 # contributors y: 354 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java x: 20 # contributors y: 357 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java x: 10 # contributors y: 256 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java x: 2 # contributors y: 411 lines of code store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java x: 99 # contributors y: 2709 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java x: 6 # contributors y: 145 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java x: 27 # contributors y: 282 lines of code client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java x: 17 # contributors y: 65 lines of code client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java x: 72 # contributors y: 1183 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java x: 14 # contributors y: 133 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java x: 4 # contributors y: 139 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsHelper.java x: 12 # contributors y: 178 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java x: 37 # contributors y: 495 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java x: 13 # contributors y: 122 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/TopicStatsTable.java x: 2 # contributors y: 21 lines of code store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java x: 24 # contributors y: 698 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java x: 7 # contributors y: 91 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java x: 14 # contributors y: 438 lines of code broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java x: 3 # contributors y: 195 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java x: 37 # contributors y: 769 lines of code broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java x: 21 # contributors y: 321 lines of code common/src/main/java/org/apache/rocketmq/common/MixAll.java x: 66 # contributors y: 473 lines of code store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java x: 12 # contributors y: 139 lines of code common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItem.java x: 11 # contributors y: 54 lines of code common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java x: 21 # contributors y: 101 lines of code common/src/main/java/org/apache/rocketmq/common/stats/StatsItem.java x: 19 # contributors y: 206 lines of code common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java x: 24 # contributors y: 225 lines of code store/src/main/java/org/apache/rocketmq/store/CommitLog.java x: 83 # contributors y: 1970 lines of code store/src/main/java/org/apache/rocketmq/store/index/IndexService.java x: 15 # contributors y: 321 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java x: 14 # contributors y: 266 lines of code store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java x: 50 # contributors y: 910 lines of code store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueStore.java x: 6 # contributors y: 444 lines of code broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java x: 23 # contributors y: 697 lines of code client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java x: 87 # contributors y: 1578 lines of code client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java x: 61 # contributors y: 741 lines of code example/src/main/java/org/apache/rocketmq/example/simple/PopConsumer.java x: 2 # contributors y: 45 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java x: 25 # contributors y: 1673 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerPathConfigHelper.java x: 12 # contributors y: 48 lines of code broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerLagCalculator.java x: 8 # contributors y: 444 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java x: 15 # contributors y: 189 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/NotifyResult.java x: 1 # contributors y: 23 lines of code client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java x: 7 # contributors y: 615 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java x: 6 # contributors y: 410 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreFetcherImpl.java x: 3 # contributors y: 378 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java x: 13 # contributors y: 248 lines of code broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java x: 24 # contributors y: 219 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java x: 42 # contributors y: 624 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java x: 60 # contributors y: 1064 lines of code client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIFactory.java x: 4 # contributors y: 115 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java x: 16 # contributors y: 166 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManagerFactory.java x: 6 # contributors y: 22 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java x: 46 # contributors y: 552 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java x: 43 # contributors y: 658 lines of code filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParser.java x: 10 # contributors y: 429 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java x: 10 # contributors y: 75 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumeStatsRequestHeader.java x: 4 # contributors y: 67 lines of code store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java x: 11 # contributors y: 367 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/AckMessageActivity.java x: 9 # contributors y: 174 lines of code common/src/main/java/org/apache/rocketmq/common/config/AbstractRocksDBStorage.java x: 9 # contributors y: 495 lines of code store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueOffsetTable.java x: 3 # contributors y: 555 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataInRocksDBCommand.java x: 5 # contributors y: 108 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/metadata/RocksDBConfigToJsonCommand.java x: 5 # contributors y: 271 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java x: 31 # contributors y: 616 lines of code store/src/main/java/org/apache/rocketmq/store/rocksdb/RocksDBOptionsFactory.java x: 4 # contributors y: 186 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/RecallMessageProcessor.java x: 1 # contributors y: 157 lines of code common/src/main/java/org/apache/rocketmq/common/message/Message.java x: 24 # contributors y: 191 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/ProducerProcessor.java x: 15 # contributors y: 224 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreDispatcherImpl.java x: 3 # contributors y: 324 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java x: 34 # contributors y: 651 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerCache.java x: 1 # contributors y: 242 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportPopRecordCommand.java x: 1 # contributors y: 82 lines of code auth/src/main/java/org/apache/rocketmq/auth/authorization/builder/DefaultAuthorizationContextBuilder.java x: 3 # contributors y: 465 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java x: 56 # contributors y: 1325 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java x: 16 # contributors y: 256 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java x: 21 # contributors y: 299 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java x: 8 # contributors y: 90 lines of code store/src/main/java/org/apache/rocketmq/store/MessageStore.java x: 35 # contributors y: 166 lines of code store/src/main/java/org/apache/rocketmq/store/plugin/AbstractPluginMessageStore.java x: 10 # contributors y: 531 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java x: 59 # contributors y: 593 lines of code client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java x: 16 # contributors y: 87 lines of code client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java x: 7 # contributors y: 107 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java x: 22 # contributors y: 211 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceType.java x: 10 # contributors y: 8 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/RequestMapping.java x: 7 # contributors y: 38 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/DefaultGrpcMessingActivity.java x: 11 # contributors y: 128 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java x: 14 # contributors y: 424 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessingActivity.java x: 8 # contributors y: 46 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java x: 12 # contributors y: 330 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java x: 16 # contributors y: 307 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/MessagingProcessor.java x: 13 # contributors y: 284 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/message/ClusterMessageService.java x: 12 # contributors y: 244 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalMessageService.java x: 16 # contributors y: 467 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/message/MessageService.java x: 10 # contributors y: 135 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageResponseHeader.java x: 2 # contributors y: 93 lines of code srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java x: 16 # contributors y: 73 lines of code store/src/main/java/org/apache/rocketmq/store/stats/LmqBrokerStatsManager.java x: 3 # contributors y: 54 lines of code store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java x: 64 # contributors y: 1348 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java x: 28 # contributors y: 388 lines of code client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java x: 2 # contributors y: 454 lines of code client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java x: 7 # contributors y: 63 lines of code common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java x: 41 # contributors y: 565 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConsumerOffsetManagerV2.java x: 1 # contributors y: 320 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java x: 1 # contributors y: 142 lines of code common/src/main/java/org/apache/rocketmq/common/config/ConfigHelper.java x: 1 # contributors y: 104 lines of code common/src/main/java/org/apache/rocketmq/common/config/ConfigRocksDBStorage.java x: 4 # contributors y: 106 lines of code container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java x: 14 # contributors y: 250 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java x: 31 # contributors y: 337 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java x: 47 # contributors y: 724 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java x: 12 # contributors y: 227 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/FileSegment.java x: 1 # contributors y: 271 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/common/Address.java x: 6 # contributors y: 62 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ProxyTopicRouteData.java x: 9 # contributors y: 116 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroup.java x: 9 # contributors y: 280 lines of code broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotifyMessageArrivingListener.java x: 9 # contributors y: 25 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java x: 28 # contributors y: 511 lines of code store/src/main/java/org/apache/rocketmq/store/queue/AbstractConsumeQueueStore.java x: 3 # contributors y: 88 lines of code store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueue.java x: 4 # contributors y: 366 lines of code common/src/main/java/org/apache/rocketmq/common/constant/PermName.java x: 11 # contributors y: 45 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java x: 11 # contributors y: 268 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java x: 31 # contributors y: 309 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java x: 21 # contributors y: 146 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolTlsHelper.java x: 2 # contributors y: 83 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java x: 51 # contributors y: 1071 lines of code store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java x: 16 # contributors y: 288 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyLogger.java x: 10 # contributors y: 287 lines of code broker/src/main/java/org/apache/rocketmq/broker/metrics/PopMetricsManager.java x: 3 # contributors y: 187 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/BroadcastOffsetManager.java x: 3 # contributors y: 159 lines of code common/src/main/java/org/apache/rocketmq/common/ServiceThread.java x: 19 # contributors y: 96 lines of code common/src/main/java/org/apache/rocketmq/common/message/MessageExtBrokerInner.java x: 10 # contributors y: 71 lines of code example/src/main/java/org/apache/rocketmq/example/lmq/LMQProducer.java x: 2 # contributors y: 34 lines of code store/src/main/java/org/apache/rocketmq/store/AppendMessageStatus.java x: 2 # contributors y: 9 lines of code store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java x: 46 # contributors y: 979 lines of code store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java x: 13 # contributors y: 202 lines of code store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java x: 8 # contributors y: 287 lines of code store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java x: 17 # contributors y: 499 lines of code store/src/main/java/org/apache/rocketmq/store/queue/QueueOffsetOperator.java x: 4 # contributors y: 87 lines of code store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueTable.java x: 4 # contributors y: 291 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metrics/TieredStoreMetricsManager.java x: 5 # contributors y: 281 lines of code common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsBriefInterceptor.java x: 5 # contributors y: 47 lines of code common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledIncrementPrinter.java x: 7 # contributors y: 209 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicQueueMappingUtils.java x: 4 # contributors y: 588 lines of code broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java x: 14 # contributors y: 335 lines of code broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java x: 20 # contributors y: 681 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java x: 23 # contributors y: 303 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java x: 10 # contributors y: 152 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/PopStatus.java x: 5 # contributors y: 7 lines of code common/src/main/java/org/apache/rocketmq/common/utils/ServiceProvider.java x: 9 # contributors y: 139 lines of code openmessaging/src/main/java/io/openmessaging/rocketmq/promise/DefaultPromise.java x: 7 # contributors y: 178 lines of code store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java x: 23 # contributors y: 262 lines of code store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java x: 7 # contributors y: 305 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java x: 19 # contributors y: 479 lines of code store/src/main/java/org/apache/rocketmq/store/queue/CqUnit.java x: 5 # contributors y: 75 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java x: 12 # contributors y: 133 lines of code auth/src/main/java/org/apache/rocketmq/auth/authorization/factory/AuthorizationFactory.java x: 2 # contributors y: 127 lines of code broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java x: 3 # contributors y: 33 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java x: 37 # contributors y: 486 lines of code client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java x: 34 # contributors y: 404 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java x: 23 # contributors y: 309 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java x: 21 # contributors y: 265 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java x: 6 # contributors y: 87 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommand.java x: 18 # contributors y: 169 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeOldCommand.java x: 6 # contributors y: 105 lines of code common/src/main/java/org/apache/rocketmq/common/ConfigManager.java x: 13 # contributors y: 66 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/receipt/DefaultReceiptHandleManager.java x: 5 # contributors y: 246 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceBean.java x: 10 # contributors y: 113 lines of code common/src/main/java/org/apache/rocketmq/common/UtilAll.java x: 51 # contributors y: 638 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ClientManagerActivity.java x: 6 # contributors y: 165 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/MessageStoreConfig.java x: 1 # contributors y: 290 lines of code broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java x: 46 # contributors y: 1271 lines of code common/src/main/java/org/apache/rocketmq/common/stats/Stats.java x: 4 # contributors y: 31 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java x: 13 # contributors y: 396 lines of code client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java x: 9 # contributors y: 86 lines of code client/src/main/java/org/apache/rocketmq/client/ClientConfig.java x: 41 # contributors y: 414 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java x: 30 # contributors y: 378 lines of code store/src/main/java/org/apache/rocketmq/store/logfile/DefaultMappedFile.java x: 14 # contributors y: 753 lines of code store/src/main/java/org/apache/rocketmq/store/queue/BatchConsumeQueue.java x: 16 # contributors y: 949 lines of code store/src/main/java/org/apache/rocketmq/store/queue/SparseConsumeQueue.java x: 4 # contributors y: 321 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/route/ZoneRouteRPCHook.java x: 5 # contributors y: 71 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceConstants.java x: 14 # contributors y: 25 lines of code client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionOpenTracingHookImpl.java x: 6 # contributors y: 48 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/ConsumerProcessor.java x: 13 # contributors y: 499 lines of code broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java x: 19 # contributors y: 128 lines of code common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolMonitor.java x: 10 # contributors y: 101 lines of code proxy/src/main/resources/rmq.proxy.logback.xml x: 7 # contributors y: 403 lines of code broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsConstant.java x: 3 # contributors y: 43 lines of code broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsManager.java x: 11 # contributors y: 605 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/BatchProducer.java x: 17 # contributors y: 360 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/Producer.java x: 27 # contributors y: 369 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java x: 41 # contributors y: 485 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java x: 21 # contributors y: 235 lines of code client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java x: 11 # contributors y: 254 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java x: 19 # contributors y: 146 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java x: 13 # contributors y: 29 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java x: 2 # contributors y: 290 lines of code auth/src/main/java/org/apache/rocketmq/auth/authentication/manager/AuthenticationMetadataManagerImpl.java x: 2 # contributors y: 189 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SimpleSubscriptionData.java x: 2 # contributors y: 62 lines of code client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java x: 30 # contributors y: 245 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java x: 36 # contributors y: 386 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopOrderlyService.java x: 10 # contributors y: 334 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java x: 16 # contributors y: 57 lines of code client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java x: 13 # contributors y: 111 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/ClusterMetadataService.java x: 13 # contributors y: 237 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java x: 4 # contributors y: 171 lines of code auth/src/main/java/org/apache/rocketmq/auth/authorization/provider/LocalAuthorizationMetadataProvider.java x: 1 # contributors y: 167 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java x: 31 # contributors y: 252 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java x: 25 # contributors y: 81 lines of code broker/src/main/resources/rmq.broker.logback.xml x: 8 # contributors y: 664 lines of code client/src/main/java/org/apache/rocketmq/client/MQAdmin.java x: 12 # contributors y: 21 lines of code common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java x: 27 # contributors y: 40 lines of code container/src/main/java/org/apache/rocketmq/container/BrokerContainer.java x: 14 # contributors y: 384 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/config/Configuration.java x: 12 # contributors y: 68 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigurationManager.java x: 9 # contributors y: 38 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/ContextInterceptor.java x: 7 # contributors y: 19 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseBuilder.java x: 10 # contributors y: 89 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/transaction/EndTransactionActivity.java x: 7 # contributors y: 57 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannel.java x: 4 # contributors y: 222 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/Http2ProtocolProxyHandler.java x: 5 # contributors y: 96 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java x: 9 # contributors y: 17 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionData.java x: 6 # contributors y: 85 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/RemotingService.java x: 6 # contributors y: 9 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/NamespaceUtil.java x: 2 # contributors y: 107 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSerializable.java x: 14 # contributors y: 55 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/DeleteTopicRequestHeader.java x: 3 # contributors y: 24 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetMaxOffsetRequestHeader.java x: 2 # contributors y: 54 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PopMessageRequestHeader.java x: 3 # contributors y: 137 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PullMessageRequestHeader.java x: 2 # contributors y: 255 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryConsumerOffsetRequestHeader.java x: 3 # contributors y: 62 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ReplyMessageRequestHeader.java x: 3 # contributors y: 129 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeaderV2.java x: 3 # contributors y: 274 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/AlterSyncStateSetRequestHeader.java x: 4 # contributors y: 56 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/admin/CleanControllerBrokerDataRequestHeader.java x: 3 # contributors y: 76 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java x: 48 # contributors y: 1071 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java x: 30 # contributors y: 188 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java x: 11 # contributors y: 212 lines of code common/src/main/java/org/apache/rocketmq/common/namesrv/DefaultTopAddressing.java x: 9 # contributors y: 128 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ClusterTopicRouteService.java x: 10 # contributors y: 32 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java x: 26 # contributors y: 297 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java x: 3 # contributors y: 180 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java x: 14 # contributors y: 235 lines of code broker/src/main/java/org/apache/rocketmq/broker/plugin/PullMessageResultHandler.java x: 5 # contributors y: 22 lines of code controller/src/main/java/org/apache/rocketmq/controller/ControllerStartup.java x: 11 # contributors y: 120 lines of code controller/src/main/java/org/apache/rocketmq/controller/elect/ElectPolicy.java x: 3 # contributors y: 6 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/BrokerLiveInfo.java x: 2 # contributors y: 113 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/manager/RaftReplicasInfoManager.java x: 1 # contributors y: 201 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManager.java x: 15 # contributors y: 568 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/manager/SyncStateInfo.java x: 10 # contributors y: 56 lines of code controller/src/main/java/org/apache/rocketmq/controller/metrics/ControllerMetricsManager.java x: 3 # contributors y: 311 lines of code controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java x: 15 # contributors y: 294 lines of code controller/src/main/resources/rmq.controller.logback.xml x: 6 # contributors y: 152 lines of code example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java x: 19 # contributors y: 31 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java x: 35 # contributors y: 566 lines of code client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java x: 17 # contributors y: 25 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java x: 8 # contributors y: 13 lines of code store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsManager.java x: 5 # contributors y: 216 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingCleanService.java x: 9 # contributors y: 297 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java x: 23 # contributors y: 206 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java x: 31 # contributors y: 319 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/TransactionProducer.java x: 26 # contributors y: 399 lines of code example/src/main/java/org/apache/rocketmq/example/namespace/PullConsumerWithNamespace.java x: 11 # contributors y: 66 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java x: 12 # contributors y: 194 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ChangeInvisibleDurationActivity.java x: 8 # contributors y: 59 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity.java x: 12 # contributors y: 162 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageResponseStreamWriter.java x: 8 # contributors y: 131 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/ReceiptHandleProcessor.java x: 14 # contributors y: 44 lines of code common/src/main/java/org/apache/rocketmq/common/consumer/ReceiptHandle.java x: 6 # contributors y: 184 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ExtraInfoUtil.java x: 4 # contributors y: 261 lines of code common/src/main/java/org/apache/rocketmq/common/utils/BinaryUtil.java x: 6 # contributors y: 36 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/MQConsumerInner.java x: 4 # contributors y: 22 lines of code store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java x: 29 # contributors y: 739 lines of code common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java x: 11 # contributors y: 159 lines of code broker/src/main/java/org/apache/rocketmq/broker/filter/ExpressionForRetryMessageFilter.java x: 5 # contributors y: 59 lines of code tools/src/main/java/org/apache/rocketmq/tools/monitor/MonitorService.java x: 12 # contributors y: 261 lines of code store/src/main/java/org/apache/rocketmq/store/RunningFlags.java x: 6 # contributors y: 110 lines of code store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueInterface.java x: 12 # contributors y: 35 lines of code common/src/main/java/org/apache/rocketmq/common/message/MessageConst.java x: 29 # contributors y: 123 lines of code controller/src/main/java/org/apache/rocketmq/controller/BrokerHousekeepingService.java x: 8 # contributors y: 31 lines of code example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java x: 18 # contributors y: 102 lines of code common/src/main/java/org/apache/rocketmq/common/topic/TopicValidator.java x: 11 # contributors y: 106 lines of code store/src/main/java/org/apache/rocketmq/store/CommitLogDispatcher.java x: 4 # contributors y: 5 lines of code store/src/main/java/org/apache/rocketmq/store/ha/HAService.java x: 37 # contributors y: 39 lines of code store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAClient.java x: 16 # contributors y: 443 lines of code store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java x: 20 # contributors y: 456 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncer.java x: 5 # contributors y: 203 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java x: 11 # contributors y: 30 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/metrics/ProxyMetricsManager.java x: 8 # contributors y: 215 lines of code store/src/main/java/org/apache/rocketmq/store/TopicQueueLock.java x: 7 # contributors y: 31 lines of code broker/src/main/java/org/apache/rocketmq/broker/dledger/DLedgerRoleChangeHandler.java x: 14 # contributors y: 145 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicRouteInfoManager.java x: 7 # contributors y: 203 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java x: 16 # contributors y: 216 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java x: 12 # contributors y: 95 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueSelector.java x: 9 # contributors y: 253 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java x: 7 # contributors y: 82 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java x: 22 # contributors y: 158 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/connection/ProducerConnectionSubCommand.java x: 6 # contributors y: 59 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java x: 12 # contributors y: 121 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java x: 9 # contributors y: 161 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetricsCommand.java x: 10 # contributors y: 207 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java x: 9 # contributors y: 103 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java x: 8 # contributors y: 111 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java x: 12 # contributors y: 104 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java x: 9 # contributors y: 243 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByOffsetSubCommand.java x: 4 # contributors y: 83 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java x: 12 # contributors y: 155 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java x: 10 # contributors y: 159 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java x: 9 # contributors y: 81 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateStaticTopicSubCommand.java x: 7 # contributors y: 155 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicPermSubCommand.java x: 18 # contributors y: 135 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java x: 17 # contributors y: 147 lines of code example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java x: 14 # contributors y: 22 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator/TopicMessageTypeValidator.java x: 7 # contributors y: 5 lines of code client/src/main/java/org/apache/rocketmq/client/trace/hook/ConsumeMessageTraceHookImpl.java x: 14 # contributors y: 89 lines of code filter/src/main/java/org/apache/rocketmq/filter/expression/ComparisonExpression.java x: 8 # contributors y: 494 lines of code filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParserTokenManager.java x: 4 # contributors y: 973 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java x: 22 # contributors y: 237 lines of code store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java x: 20 # contributors y: 54 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/Consumer.java x: 28 # contributors y: 235 lines of code example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingPushConsumer.java x: 10 # contributors y: 42 lines of code openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/PushConsumerImpl.java x: 7 # contributors y: 162 lines of code store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java x: 14 # contributors y: 558 lines of code client/src/main/java/org/apache/rocketmq/client/impl/admin/MqClientAdminImpl.java x: 1 # contributors y: 395 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java x: 16 # contributors y: 144 lines of code store/src/main/java/org/apache/rocketmq/store/AppendMessageCallback.java x: 11 # contributors y: 10 lines of code store/src/main/java/org/apache/rocketmq/store/kv/CompactionLog.java x: 4 # contributors y: 940 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BrokerReplicasInfo.java x: 3 # contributors y: 148 lines of code store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java x: 19 # contributors y: 186 lines of code store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAClient.java x: 10 # contributors y: 312 lines of code store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAConnection.java x: 12 # contributors y: 363 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/rpc/ClientMetadata.java x: 4 # contributors y: 123 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/common/ServiceThread.java x: 12 # contributors y: 49 lines of code common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java x: 16 # contributors y: 121 lines of code broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotificationRequest.java x: 5 # contributors y: 31 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java x: 18 # contributors y: 43 lines of code distribution/release.xml x: 24 # contributors y: 92 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannel.java x: 8 # contributors y: 137 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerPreOnlineService.java x: 7 # contributors y: 233 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageCheckService.java x: 16 # contributors y: 38 lines of code container/src/main/java/org/apache/rocketmq/container/BrokerContainerStartup.java x: 12 # contributors y: 343 lines of code store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java x: 21 # contributors y: 536 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/timer/TimerProducer.java x: 7 # contributors y: 249 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java x: 15 # contributors y: 157 lines of code openmessaging/src/main/java/io/openmessaging/rocketmq/producer/ProducerImpl.java x: 5 # contributors y: 112 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/ChannelManager.java x: 9 # contributors y: 65 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/Configuration.java x: 3 # contributors y: 243 lines of code store/src/main/java/org/apache/rocketmq/store/ha/WaitNotifyObject.java x: 16 # contributors y: 85 lines of code store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/EpochFileCache.java x: 9 # contributors y: 264 lines of code example/src/main/java/org/apache/rocketmq/example/broadcast/PushConsumer.java x: 16 # contributors y: 25 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/TopicRouteData.java x: 1 # contributors y: 175 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/CommandUtil.java x: 17 # contributors y: 143 lines of code dev/merge_rocketmq_pr.py x: 3 # contributors y: 298 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceView.java x: 6 # contributors y: 131 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/timer/TimerConsumer.java x: 5 # contributors y: 141 lines of code example/src/main/java/org/apache/rocketmq/example/batch/SplitBatchProducer.java x: 8 # contributors y: 74 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceDispatcher.java x: 13 # contributors y: 14 lines of code broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java x: 11 # contributors y: 230 lines of code common/src/main/java/org/apache/rocketmq/common/TopicConfig.java x: 9 # contributors y: 207 lines of code common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java x: 8 # contributors y: 5 lines of code common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java x: 20 # contributors y: 33 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannelHandlerContext.java x: 5 # contributors y: 184 lines of code store/src/main/java/org/apache/rocketmq/store/ha/HAConnection.java x: 22 # contributors y: 13 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/consumer/DeleteSubscriptionGroupCommand.java x: 11 # contributors y: 83 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/DledgerController.java x: 1 # contributors y: 479 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettySystemConfig.java x: 15 # contributors y: 51 lines of code common/src/main/java/org/apache/rocketmq/common/utils/NameServerAddressUtils.java x: 15 # contributors y: 29 lines of code
3092.0
lines of code
  min: 1.0
  average: 113.96
  25th percentile: 22.0
  median: 47.0
  75th percentile: 111.25
  max: 3092.0
0 99.0
# contributors
min: 1.0 | average: 6.66 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 8.0 | max: 99.0