apache / rocketmq
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 1,311 files with 149,633 lines of code in files.
    • 856 files that are 366+ days old (115,841 lines of code)
    • 369 files that are 181-365 days old (25,362 lines of code)
    • 25 files that are 91-180 days old (2,332 lines of code)
    • 47 files that are 31-90 days old (4,349 lines of code)
    • 14 files that are 1-30 days old (1,749 lines of code)
77% | 16% | 1% | 2% | 1%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 1,311 files with 149,633 lines of code in files.
    • 359 files have been last changed 366+ days ago (11,992 lines of code)
    • 547 files have been last changed 181-365 days ago (43,064 lines of code)
    • 149 files have been last changed 91-180 days ago (24,071 lines of code)
    • 167 files have been last changed 31-90 days ago (33,770 lines of code)
    • 89 files have been last changed 1-30 days ago (36,736 lines of code)
8% | 28% | 16% | 22% | 24%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, md, xml, yml, sh, cmd, properties, json, yaml, py, sql, bzl, gitignore, txt
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java78% | 16% | 1% | 2% | 1%
xml23% | 76% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
yml100% | 0% | 0% | 0% | 0%
sql100% | 0% | 0% | 0% | 0%
bzl0% | 100% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java7% | 28% | 15% | 22% | 24%
xml12% | 10% | 38% | 1% | 35%
yml100% | 0% | 0% | 0% | 0%
sql100% | 0% | 0% | 0% | 0%
py0% | 100% | 0% | 0% | 0%
bzl0% | 100% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
broker86% | 9% | 1% | 1% | 1%
store87% | 12% | <1% | <1% | <1%
client92% | <1% | 5% | 0% | 2%
tools95% | 1% | <1% | 2% | 0%
proxy71% | 23% | <1% | 3% | <1%
common86% | 4% | <1% | 1% | 6%
remoting27% | 70% | <1% | 1% | 0%
example96% | 3% | 0% | 0% | 0%
filter100% | 0% | 0% | 0% | 0%
namesrv92% | 7% | 0% | 0% | 0%
acl96% | 0% | 3% | 0% | 0%
controller66% | 10% | 10% | 12% | 0%
openmessaging100% | 0% | 0% | 0% | 0%
container100% | 0% | 0% | 0% | 0%
dev100% | 0% | 0% | 0% | 0%
srvutil100% | 0% | 0% | 0% | 0%
style89% | 11% | 0% | 0% | 0%
distribution100% | 0% | 0% | 0% | 0%
tieredstore0% | 59% | 0% | 40% | 0%
bazel0% | 100% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
common22% | 32% | 4% | 19% | 20%
tools15% | 47% | 8% | 8% | 19%
client8% | 17% | 20% | 25% | 28%
broker4% | 26% | 16% | 13% | 40%
proxy5% | 22% | 12% | 43% | 16%
filter21% | 6% | 0% | 72% | 0%
store2% | 20% | 30% | 19% | 26%
example16% | 40% | 4% | 38% | <1%
remoting3% | 57% | 18% | 8% | 12%
openmessaging32% | 56% | 10% | 0% | 0%
acl21% | 8% | 28% | 24% | 17%
style59% | 29% | 0% | 11% | 0%
container9% | 56% | 0% | 34% | 0%
distribution43% | 56% | 0% | 0% | 0%
srvutil20% | 79% | 0% | 0% | 0%
namesrv<1% | 32% | 3% | 21% | 41%
controller<1% | 15% | 33% | 51% | 0%
dev0% | 100% | 0% | 0% | 0%
bazel0% | 100% | 0% | 0% | 0%
tieredstore0% | <1% | 0% | 46% | 53%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
MQClientAPIImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 2851 126 2016-12-27 2023-08-03 126 71 yukon@apache.org 34032341+koado@users.norepl...
DefaultMessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 2624 205 2016-12-27 2023-08-03 177 87 yukon@apache.org 34032341+koado@users.norepl...
AdminBrokerProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 2377 78 2016-12-27 2023-08-03 113 70 yukon@apache.org 34032341+koado@users.norepl...
BrokerController.java
in broker/src/main/java/org/apache/rocketmq/broker
 1942 159 2016-12-27 2023-08-04 159 72 yukon@apache.org 2573259572@qq.com
CommitLog.java
in store/src/main/java/org/apache/rocketmq/store
 1788 112 2016-12-27 2023-07-11 115 75 yukon@apache.org juntao.jjt@alibaba-inc.com
DefaultMQAdminExtImpl.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 1698 128 2016-12-27 2023-08-03 97 60 yukon@apache.org 34032341+koado@users.norepl...
DefaultMQProducerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/producer
 1424 93 2016-12-27 2023-07-21 116 75 yukon@apache.org 36399867+guyinyou@users.nor...
DefaultMQPushConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1285 84 2016-12-27 2023-03-14 74 48 yukon@apache.org ljbmxsm@gmail.com
MessageStoreConfig.java
in store/src/main/java/org/apache/rocketmq/store/config
 1228 330 2016-12-27 2023-08-04 86 56 yukon@apache.org 2573259572@qq.com
BrokerOuterAPI.java
in broker/src/main/java/org/apache/rocketmq/broker/out
 1224 60 2016-12-27 2023-07-25 77 41 yukon@apache.org jinrongtong5@163.com
BrokerConfig.java
in common/src/main/java/org/apache/rocketmq/common
 1174 328 2016-12-27 2023-07-25 114 55 yukon@apache.org jinrongtong5@163.com
MQClientInstance.java
in client/src/main/java/org/apache/rocketmq/client/impl/factory
 1080 61 2016-12-27 2023-06-14 100 64 yukon@apache.org 464473306@qq.com
RouteInfoManager.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo
 1071 66 2016-12-27 2023-07-25 70 44 yukon@apache.org jinrongtong5@163.com
ConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store
 1032 58 2016-12-27 2023-08-03 66 44 yukon@apache.org 34032341+koado@users.norepl...
NettyRemotingClient.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 885 47 2016-12-27 2023-07-27 82 49 yukon@apache.org cool8511@gmail.com
PullMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 743 16 2016-12-27 2023-06-05 53 33 yukon@apache.org 464473306@qq.com
DefaultMQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 733 127 2016-12-27 2023-08-03 78 49 yukon@apache.org 34032341+koado@users.norepl...
MappedFileQueue.java
in store/src/main/java/org/apache/rocketmq/store
 722 50 2016-12-27 2023-06-22 43 27 yukon@apache.org 845238369@qq.com
DefaultMQPullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 691 67 2016-12-27 2023-06-25 55 40 yukon@apache.org panzhi33@qq.com
RebalanceImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 691 28 2016-12-27 2022-11-21 44 30 yukon@apache.org yangkun.ayk@gmail.com
UtilAll.java
in common/src/main/java/org/apache/rocketmq/common
 679 53 2016-12-27 2023-05-30 68 46 yukon@apache.org 87409330+ther1sing3un@users...
BrokerStatsManager.java
in store/src/main/java/org/apache/rocketmq/store/stats
 654 64 2016-12-27 2023-02-07 35 21 yukon@apache.org wqdyxnbd@163.com
NettyRemotingServer.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 649 58 2016-12-27 2023-07-14 64 38 yukon@apache.org dingshuangxi888@gmail.com
DefaultMQProducer.java
in client/src/main/java/org/apache/rocketmq/client/producer
 649 102 2016-12-27 2023-07-21 82 47 yukon@apache.org 36399867+guyinyou@users.nor...
MQVersion.java
in common/src/main/java/org/apache/rocketmq/common
 633 2 2016-12-27 2023-06-23 55 24 yukon@apache.org jinrongtong5@163.com
DefaultRequestProcessor.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/processor
 566 29 2016-12-27 2023-06-01 56 33 yukon@apache.org jinrongtong5@163.com
SendMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 560 10 2016-12-27 2023-03-19 92 55 yukon@apache.org juntao.jjt@alibaba-inc.com
MessageDecoder.java
in common/src/main/java/org/apache/rocketmq/common/message
 540 20 2016-12-27 2023-01-03 55 39 yukon@apache.org ljbmxsm@gmail.com
TopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 537 33 2016-12-27 2023-08-04 58 36 yukon@apache.org 2573259572@qq.com
StoreStatsService.java
in store/src/main/java/org/apache/rocketmq/store
 536 42 2016-12-27 2022-11-24 34 21 yukon@apache.org yangkun.ayk@gmail.com
RemotingCommand.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 496 59 2016-12-27 2023-08-03 39 25 yukon@apache.org 34032341+koado@users.norepl...
NettyRemotingAbstract.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 493 24 2016-12-27 2023-04-13 61 37 yukon@apache.org 56945247+lyx2000@users.nore...
AbstractSendMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 490 18 2016-12-27 2023-01-11 52 34 yukon@apache.org jinrongtong5@163.com
ConsumeMessageOrderlyService.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 483 25 2016-12-27 2023-06-25 57 38 yukon@apache.org panzhi33@qq.com
DefaultMQPushConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 465 101 2016-12-27 2023-05-10 64 34 yukon@apache.org ljbmxsm@gmail.com
MixAll.java
in common/src/main/java/org/apache/rocketmq/common
 441 35 2016-12-27 2023-06-14 88 60 yukon@apache.org 464473306@qq.com
TransactionProducer.java
in example/src/main/java/org/apache/rocketmq/example/benchmark
 400 17 2016-12-27 2023-05-27 34 26 yukon@apache.org 53332773+dl1231@users.norep...
MQAdminImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 389 22 2016-12-27 2023-08-03 43 31 yukon@apache.org 34032341+koado@users.norepl...
ConsumeMessageConcurrentlyService.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 386 21 2016-12-27 2023-06-25 50 35 yukon@apache.org panzhi33@qq.com
ProcessQueue.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 379 32 2016-12-27 2023-05-10 35 25 yukon@apache.org ljbmxsm@gmail.com
Producer.java
in example/src/main/java/org/apache/rocketmq/example/benchmark
 369 11 2016-12-27 2023-05-27 39 27 yukon@apache.org 53332773+dl1231@users.norep...
ConsumerOffsetManager.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 337 28 2016-12-27 2023-08-04 27 18 yukon@apache.org 2573259572@qq.com
IndexService.java
in store/src/main/java/org/apache/rocketmq/store/index
 321 15 2016-12-27 2022-11-24 22 14 yukon@apache.org yangkun.ayk@gmail.com
PullAPIWrapper.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 319 16 2016-12-27 2022-11-21 42 31 yukon@apache.org yangkun.ayk@gmail.com
MQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 307 - 2016-12-27 2023-06-05 69 43 yukon@apache.org 464473306@qq.com
ClientConfig.java
in client/src/main/java/org/apache/rocketmq/client
 305 53 2016-12-27 2023-06-14 55 38 yukon@apache.org 464473306@qq.com
ConsumerProgressSubCommand.java
in tools/src/main/java/org/apache/rocketmq/tools/command/consumer
 304 23 2016-12-27 2022-11-21 31 21 yukon@apache.org yangkun.ayk@gmail.com
DefaultMQPullConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 302 60 2016-12-27 2022-11-11 39 26 yukon@apache.org admin@lv5.moe
ConsumerManageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 294 9 2016-12-27 2023-01-09 27 18 yukon@apache.org admin@lv5.moe
SubscriptionGroupManager.java
in broker/src/main/java/org/apache/rocketmq/broker/subscription
 291 30 2016-12-27 2023-08-04 25 18 yukon@apache.org 2573259572@qq.com
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
transaction.sql
in broker/src/main/resources
 4 - 2016-12-27 2016-12-27 1 1 yukon@apache.org yukon@apache.org
MessageListener.java
in client/src/main/java/org/apache/rocketmq/client/consumer/listener
 3 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
MQAdminExtInner.java
in client/src/main/java/org/apache/rocketmq/client/admin
 3 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
NamesrvUtil.java
in common/src/main/java/org/apache/rocketmq/common/namesrv
 4 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
FlushDiskType.java
in store/src/main/java/org/apache/rocketmq/store/config
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
FilterMessageHook.java
in client/src/main/java/org/apache/rocketmq/client/hook
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
PullTaskCallback.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
PullCallback.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeConcurrentlyStatus.java
in client/src/main/java/org/apache/rocketmq/client/consumer/listener
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
MessageFilter.java
in common/src/main/java/org/apache/rocketmq/common/filter
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
CommandCustomHeader.java
in remoting/src/main/java/org/apache/rocketmq/remoting
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
InvokeCallback.java
in remoting/src/main/java/org/apache/rocketmq/remoting
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingCommandType.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
BrokerRole.java
in store/src/main/java/org/apache/rocketmq/store/config
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
SendMessageHook.java
in client/src/main/java/org/apache/rocketmq/client/hook
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeMessageHook.java
in client/src/main/java/org/apache/rocketmq/client/hook
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
CheckForbiddenHook.java
in client/src/main/java/org/apache/rocketmq/client/hook
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ReadOffsetType.java
in client/src/main/java/org/apache/rocketmq/client/consumer/store
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
LocalTransactionState.java
in client/src/main/java/org/apache/rocketmq/client/producer
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
CommunicationMode.java
in client/src/main/java/org/apache/rocketmq/client/impl
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
Operand.java
in common/src/main/java/org/apache/rocketmq/common/filter/impl
 6 1 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
SystemClock.java
in common/src/main/java/org/apache/rocketmq/common
 6 1 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
Apache.xml
in style/copyright
 6 - 2016-12-28 2016-12-29 2 1 yukon@apache.org yukon@apache.org
ConsumeMessageHook.java
in broker/src/main/java/org/apache/rocketmq/broker/mqtrace
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
MessageQueueListener.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
PullStatus.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
LatencyFaultTolerance.java
in client/src/main/java/org/apache/rocketmq/client/latency
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
MessageQueueSelector.java
in client/src/main/java/org/apache/rocketmq/client/producer
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
SendStatus.java
in client/src/main/java/org/apache/rocketmq/client/producer
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ServiceState.java
in common/src/main/java/org/apache/rocketmq/common
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingTooMuchRequestException.java
in remoting/src/main/java/org/apache/rocketmq/remoting/exception
 7 1 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
NettyEventType.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
AppendMessageStatus.java
in store/src/main/java/org/apache/rocketmq/store
 8 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeReturnType.java
in client/src/main/java/org/apache/rocketmq/client/consumer/listener
 8 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
Type.java
in common/src/main/java/org/apache/rocketmq/common/filter/impl
 8 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RunningStats.java
in common/src/main/java/org/apache/rocketmq/common/running
 8 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingSysResponseCode.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 8 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ChannelEventListener.java
in remoting/src/main/java/org/apache/rocketmq/remoting
 8 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeOrderlyStatus.java
in client/src/main/java/org/apache/rocketmq/client/consumer/listener
 9 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
FilterContext.java
in common/src/main/java/org/apache/rocketmq/common/filter
 10 2 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingSendRequestException.java
in remoting/src/main/java/org/apache/rocketmq/remoting/exception
 10 2 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingException.java
in remoting/src/main/java/org/apache/rocketmq/remoting/exception
 10 2 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingCommandException.java
in remoting/src/main/java/org/apache/rocketmq/remoting/exception
 10 2 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ImportantField.java
in common/src/main/java/org/apache/rocketmq/common/annotation
 11 - 2016-12-27 2016-12-29 2 1 yukon@apache.org yukon@apache.org
CFNullable.java
in remoting/src/main/java/org/apache/rocketmq/remoting/annotation
 11 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
CFNotNull.java
in remoting/src/main/java/org/apache/rocketmq/remoting/annotation
 11 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
AllocateMessageQueueStrategy.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 12 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
TransactionSendResult.java
in client/src/main/java/org/apache/rocketmq/client/producer
 12 3 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeFromWhere.java
in common/src/main/java/org/apache/rocketmq/common/consumer
 12 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
KVConfigSerializeWrapper.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig
 12 1 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
AbstractRocksDBStorage.java
in common/src/main/java/org/apache/rocketmq/common/config
 523 37 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
ConfigRocksDBStorage.java
in common/src/main/java/org/apache/rocketmq/common/config
 195 16 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBSubscriptionGroupManager.java
in broker/src/main/java/org/apache/rocketmq/broker/subscription
 81 9 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBConfigManager.java
in common/src/main/java/org/apache/rocketmq/common/config
 78 8 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBLmqConsumerOffsetManager.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 72 9 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBConsumerOffsetManager.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 72 8 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBTopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 66 8 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBLmqTopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 34 5 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBLmqSubscriptionGroupManager.java
in broker/src/main/java/org/apache/rocketmq/broker/subscription
 25 3 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBOffsetSerializeWrapper.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 13 2 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
StoreType.java
in store/src/main/java/org/apache/rocketmq/store
 12 1 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
ReceiptHandleGroupKey.java
in proxy/src/main/java/org/apache/rocketmq/proxy/common
 43 7 2023-08-01 2023-08-01 1 1 zhouxzhan@apache.org zhouxzhan@apache.org
ProduceAccumulator.java
in client/src/main/java/org/apache/rocketmq/client/producer
 438 32 2023-07-21 2023-07-21 1 1 36399867+guyinyou@users.nor... 36399867+guyinyou@users.nor...
HAProxyMessageForwarder.java
in proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy
 97 3 2023-07-21 2023-07-21 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
DefaultReceiptHandleManager.java
in proxy/src/main/java/org/apache/rocketmq/proxy/service/receipt
 246 11 2023-07-10 2023-08-01 3 2 zhouxzhan@apache.org zhouxzhan@apache.org
ProxyAndTlsProtocolNegotiator.java
in proxy/src/main/java/org/apache/rocketmq/proxy/grpc
 207 12 2023-07-04 2023-07-14 2 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AttributeKeys.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 24 1 2023-07-04 2023-07-11 2 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AttributeKeys.java
in proxy/src/main/java/org/apache/rocketmq/proxy/grpc/constant
 19 - 2023-07-04 2023-07-04 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
HAProxyConstants.java
in common/src/main/java/org/apache/rocketmq/common/constant
 9 - 2023-07-04 2023-07-04 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
RenewEvent.java
in proxy/src/main/java/org/apache/rocketmq/proxy/common
 38 6 2023-07-03 2023-08-01 3 2 zhouxzhan@apache.org zhouxzhan@apache.org
ReceiptHandleManager.java
in proxy/src/main/java/org/apache/rocketmq/proxy/service/receipt
 8 - 2023-07-03 2023-07-10 2 1 zhouxzhan@apache.org zhouxzhan@apache.org
StateEventListener.java
in common/src/main/java/org/apache/rocketmq/common/state
 4 - 2023-07-03 2023-07-03 1 1 zhouxzhan@apache.org zhouxzhan@apache.org
ContextStreamObserver.java
in proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2
 7 - 2023-06-29 2023-06-29 1 1 xdkxlk@outlook.com xdkxlk@outlook.com
MessageStoreFetcher.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore
 15 - 2023-06-27 2023-08-03 2 2 707364882@qq.com 34032341+koado@users.norepl...
BatchAck.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body
 93 19 2023-06-19 2023-06-19 1 1 zsjperiod@foxmail.com zsjperiod@foxmail.com
BitSetSerializerDeserializer.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 30 3 2023-06-19 2023-06-19 1 1 zsjperiod@foxmail.com zsjperiod@foxmail.com
BatchAckMessageRequestBody.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body
 19 4 2023-06-19 2023-06-19 1 1 zsjperiod@foxmail.com zsjperiod@foxmail.com
AttributeUtil.java
in common/src/main/java/org/apache/rocketmq/common/attribute
 99 5 2023-06-14 2023-06-14 1 1 zhouxzhan@apache.org zhouxzhan@apache.org
HeartbeatV2Result.java
in remoting/src/main/java/org/apache/rocketmq/remoting/common
 29 7 2023-06-14 2023-06-14 1 1 464473306@qq.com 464473306@qq.com
SubscriptionGroupAttributes.java
in common/src/main/java/org/apache/rocketmq/common
 10 1 2023-06-14 2023-06-14 1 1 zhouxzhan@apache.org zhouxzhan@apache.org
TieredFlatFile.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 515 31 2023-06-09 2023-08-03 4 2 707364882@qq.com 34032341+koado@users.norepl...
CompositeFlatFile.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 391 44 2023-06-09 2023-08-03 4 2 707364882@qq.com 34032341+koado@users.norepl...
TieredIndexFile.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 374 19 2023-06-09 2023-06-27 2 1 707364882@qq.com 707364882@qq.com
TieredFlatFileManager.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 238 15 2023-06-09 2023-07-19 3 1 707364882@qq.com 707364882@qq.com
TieredCommitLog.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 123 17 2023-06-09 2023-07-19 3 1 707364882@qq.com 707364882@qq.com
CompositeQueueFlatFile.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 91 8 2023-06-09 2023-07-13 2 1 707364882@qq.com 707364882@qq.com
TieredConsumeQueue.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 74 17 2023-06-09 2023-08-03 2 2 707364882@qq.com 34032341+koado@users.norepl...
FileSegmentAllocator.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider
 72 7 2023-06-09 2023-06-09 1 1 707364882@qq.com 707364882@qq.com
InFlightRequestFuture.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common
 54 7 2023-06-09 2023-06-09 1 1 707364882@qq.com 707364882@qq.com
InFlightRequestKey.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common
 41 8 2023-06-09 2023-06-09 1 1 707364882@qq.com 707364882@qq.com
TieredFileAllocator.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 30 5 2023-06-09 2023-06-09 1 1 707364882@qq.com 707364882@qq.com
CompositeAccess.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 26 - 2023-06-09 2023-08-03 2 2 707364882@qq.com 34032341+koado@users.norepl...
FileSegmentType.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common
 25 2 2023-06-09 2023-06-09 1 1 707364882@qq.com 707364882@qq.com
ColdDataCgCtrService.java
in broker/src/main/java/org/apache/rocketmq/broker/coldctr
 195 16 2023-06-05 2023-06-05 1 1 464473306@qq.com 464473306@qq.com
GetColdDataFlowCtrInfoSubCommand.java
in tools/src/main/java/org/apache/rocketmq/tools/command/broker
 94 5 2023-06-05 2023-06-05 1 1 464473306@qq.com 464473306@qq.com
CommitLogSetReadAheadSubCommand.java
in tools/src/main/java/org/apache/rocketmq/tools/command/broker
 79 5 2023-06-05 2023-06-05 1 1 464473306@qq.com 464473306@qq.com
UpdateColdDataFlowCtrGroupConfigSubCommand.java
in tools/src/main/java/org/apache/rocketmq/tools/command/broker
 74 4 2023-06-05 2023-06-05 1 1 464473306@qq.com 464473306@qq.com
ColdDataPullRequestHoldService.java
in broker/src/main/java/org/apache/rocketmq/broker/coldctr
 71 5 2023-06-05 2023-06-05 1 1 464473306@qq.com 464473306@qq.com
RemoveColdDataFlowCtrGroupConfigSubCommand.java
in tools/src/main/java/org/apache/rocketmq/tools/command/broker
 67 4 2023-06-05 2023-06-05 1 1 464473306@qq.com 464473306@qq.com
PIDAdaptiveColdCtrStrategy.java
in broker/src/main/java/org/apache/rocketmq/broker/coldctr
 56 5 2023-06-05 2023-06-05 1 1 464473306@qq.com 464473306@qq.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
BrokerController.java
in broker/src/main/java/org/apache/rocketmq/broker
 1942 159 2016-12-27 2023-08-04 159 72 yukon@apache.org 2573259572@qq.com
MessageStoreConfig.java
in store/src/main/java/org/apache/rocketmq/store/config
 1228 330 2016-12-27 2023-08-04 86 56 yukon@apache.org 2573259572@qq.com
ScheduleMessageService.java
in broker/src/main/java/org/apache/rocketmq/broker/schedule
 692 61 2022-03-14 2023-08-04 22 17 jinrongtong5@163.com 2573259572@qq.com
rmq.broker.logback.xml
in broker/src/main/resources
 623 - 2022-11-16 2023-08-04 10 6 yangkun.ayk@gmail.com 2573259572@qq.com
TopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 537 33 2016-12-27 2023-08-04 58 36 yukon@apache.org 2573259572@qq.com
AbstractRocksDBStorage.java
in common/src/main/java/org/apache/rocketmq/common/config
 523 37 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
ConsumerOffsetManager.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 337 28 2016-12-27 2023-08-04 27 18 yukon@apache.org 2573259572@qq.com
SubscriptionGroupManager.java
in broker/src/main/java/org/apache/rocketmq/broker/subscription
 291 30 2016-12-27 2023-08-04 25 18 yukon@apache.org 2573259572@qq.com
ConfigRocksDBStorage.java
in common/src/main/java/org/apache/rocketmq/common/config
 195 16 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBSubscriptionGroupManager.java
in broker/src/main/java/org/apache/rocketmq/broker/subscription
 81 9 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBConfigManager.java
in common/src/main/java/org/apache/rocketmq/common/config
 78 8 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBLmqConsumerOffsetManager.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 72 9 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBConsumerOffsetManager.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 72 8 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
ConfigManager.java
in common/src/main/java/org/apache/rocketmq/common
 70 7 2016-12-27 2023-08-04 15 10 yukon@apache.org 2573259572@qq.com
RocksDBTopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 66 8 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
LoggerName.java
in common/src/main/java/org/apache/rocketmq/common/constant
 38 - 2016-12-27 2023-08-04 31 25 yukon@apache.org 2573259572@qq.com
RocksDBLmqTopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 34 5 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
RocksDBLmqSubscriptionGroupManager.java
in broker/src/main/java/org/apache/rocketmq/broker/subscription
 25 3 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
Consumer.java
in example/src/main/java/org/apache/rocketmq/example/quickstart
 23 1 2016-12-27 2023-08-04 17 13 yukon@apache.org 2573259572@qq.com
RocksDBOffsetSerializeWrapper.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 13 2 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
StoreType.java
in store/src/main/java/org/apache/rocketmq/store
 12 1 2023-08-04 2023-08-04 1 1 2573259572@qq.com 2573259572@qq.com
MQClientAPIImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 2851 126 2016-12-27 2023-08-03 126 71 yukon@apache.org 34032341+koado@users.norepl...
DefaultMessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 2624 205 2016-12-27 2023-08-03 177 87 yukon@apache.org 34032341+koado@users.norepl...
AdminBrokerProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 2377 78 2016-12-27 2023-08-03 113 70 yukon@apache.org 34032341+koado@users.norepl...
DefaultMQAdminExtImpl.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 1698 128 2016-12-27 2023-08-03 97 60 yukon@apache.org 34032341+koado@users.norepl...
ConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store
 1032 58 2016-12-27 2023-08-03 66 44 yukon@apache.org 34032341+koado@users.norepl...
BatchConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store/queue
 927 63 2021-12-23 2023-08-03 21 15 erikfei1288@gmail.com 34032341+koado@users.norepl...
DefaultMQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 733 127 2016-12-27 2023-08-03 78 49 yukon@apache.org 34032341+koado@users.norepl...
TieredMessageFetcher.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore
 526 17 2023-01-17 2023-08-03 6 3 admin@lv5.moe 34032341+koado@users.norepl...
TieredFlatFile.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 515 31 2023-06-09 2023-08-03 4 2 707364882@qq.com 34032341+koado@users.norepl...
RemotingCommand.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 496 59 2016-12-27 2023-08-03 39 25 yukon@apache.org 34032341+koado@users.norepl...
CompositeFlatFile.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 391 44 2023-06-09 2023-08-03 4 2 707364882@qq.com 34032341+koado@users.norepl...
MQAdminImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 389 22 2016-12-27 2023-08-03 43 31 yukon@apache.org 34032341+koado@users.norepl...
TieredMessageStore.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore
 363 22 2023-01-17 2023-08-03 9 4 admin@lv5.moe 34032341+koado@users.norepl...
SparseConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store/queue
 316 23 2022-10-24 2023-08-03 3 3 ltamber12@gmail.com 34032341+koado@users.norepl...
RouteActivity.java
in proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route
 258 7 2022-05-16 2023-08-03 15 11 kaiyi.lk@alibaba-inc.com dingshuangxi888@gmail.com
MessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 160 2 2016-12-27 2023-08-03 51 33 yukon@apache.org 34032341+koado@users.norepl...
TieredConsumeQueue.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 74 17 2023-06-09 2023-08-03 2 2 707364882@qq.com 34032341+koado@users.norepl...
SearchOffsetRequestHeader.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header
 55 10 2022-11-11 2023-08-03 2 2 admin@lv5.moe 34032341+koado@users.norepl...
PermName.java
in common/src/main/java/org/apache/rocketmq/common/constant
 42 7 2016-12-27 2023-08-03 16 10 yukon@apache.org jinrongtong5@163.com
TopicMessageType.java
in common/src/main/java/org/apache/rocketmq/common/attribute
 40 4 2022-05-27 2023-08-03 9 6 zhouxiang.zzx@alibaba-inc.com dingshuangxi888@gmail.com
ConsumeQueueInterface.java
in store/src/main/java/org/apache/rocketmq/store/queue
 30 - 2021-12-23 2023-08-03 12 10 erikfei1288@gmail.com 34032341+koado@users.norepl...
CompositeAccess.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 26 - 2023-06-09 2023-08-03 2 2 707364882@qq.com 34032341+koado@users.norepl...
MessageStoreFetcher.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore
 15 - 2023-06-27 2023-08-03 2 2 707364882@qq.com 34032341+koado@users.norepl...
DefaultTopicMessageTypeValidator.java
in proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator
 13 1 2022-05-24 2023-08-03 6 7 zhouxiang.zzx@alibaba-inc.com dingshuangxi888@gmail.com
TopicMessageTypeValidator.java
in proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator
 5 - 2022-05-24 2023-08-03 5 7 zhouxiang.zzx@alibaba-inc.com dingshuangxi888@gmail.com
TieredDispatcher.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore
 466 14 2023-01-17 2023-08-01 10 2 admin@lv5.moe 707364882@qq.com
DefaultReceiptHandleManager.java
in proxy/src/main/java/org/apache/rocketmq/proxy/service/receipt
 246 11 2023-07-10 2023-08-01 3 2 zhouxzhan@apache.org zhouxzhan@apache.org
SlaveSynchronize.java
in broker/src/main/java/org/apache/rocketmq/broker/slave
 207 11 2016-12-27 2023-08-01 30 20 yukon@apache.org weihubeats@163.com
TieredStoreExecutor.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common
 76 3 2023-01-17 2023-08-01 4 2 admin@lv5.moe 707364882@qq.com