apache / rocketmq
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
17% | 15% | 28% | 16% | 22%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java17% | 15% | 28% | 16% | 22%
xml0% | 35% | 21% | 15% | 27%
py0% | 0% | 100% | 0% | 0%
bzl0% | 0% | 0% | 100% | 0%
sql0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
client35% | 11% | 30% | 7% | 15%
store27% | 29% | 22% | 8% | 10%
broker20% | 26% | 31% | 12% | 8%
tools13% | 5% | 19% | 29% | 32%
common11% | 14% | 18% | 21% | 33%
proxy7% | 0% | 43% | 21% | 28%
namesrv41% | 21% | 8% | 13% | 14%
remoting5% | 12% | 12% | 18% | 50%
filter0% | 28% | 36% | 15% | 18%
controller0% | 12% | 49% | 11% | 26%
tieredstore0% | 0% | 66% | 15% | 17%
example0% | 0% | 42% | 9% | 47%
container0% | 0% | 73% | 10% | 16%
auth0% | 0% | 17% | 43% | 39%
dev0% | 0% | 100% | 0% | 0%
openmessaging0% | 0% | 0% | 84% | 15%
style0% | 0% | 0% | 42% | 58%
bazel0% | 0% | 0% | 100% | 0%
srvutil0% | 0% | 0% | 0% | 100%
distribution0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
MQClientAPIImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 3092 145
AdminBrokerProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 2976 97
DefaultMessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 2709 218
BrokerController.java
in broker/src/main/java/org/apache/rocketmq/broker
 2119 177
CommitLog.java
in store/src/main/java/org/apache/rocketmq/store
 1970 114
DefaultMQAdminExtImpl.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 1791 142
TimerMessageStore.java
in store/src/main/java/org/apache/rocketmq/store/timer
 1673 100
DefaultMQProducerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/producer
 1578 100
BrokerConfig.java
in common/src/main/java/org/apache/rocketmq/common
 1424 399
MessageStoreConfig.java
in store/src/main/java/org/apache/rocketmq/store/config
 1348 364
DefaultMQPushConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1325 87
BrokerOuterAPI.java
in broker/src/main/java/org/apache/rocketmq/broker/out
 1271 63
MQClientInstance.java
in client/src/main/java/org/apache/rocketmq/client/impl/factory
 1183 68
ProxyConfig.java
in proxy/src/main/java/org/apache/rocketmq/proxy/config
 1136 305
DefaultLitePullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1071 92
RouteInfoManager.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo
 1071 66
NettyRemotingClient.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 1064 60
ConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store
 979 57
SelectorParserTokenManager.java
in filter/src/main/java/org/apache/rocketmq/filter/parser
 973 26
BatchConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store/queue
 949 66
PopMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 943 36
CompactionLog.java
in store/src/main/java/org/apache/rocketmq/store/kv
 940 63
DLedgerCommitLog.java
in store/src/main/java/org/apache/rocketmq/store/dledger
 910 50
DefaultMQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 820 143
PopBufferMergeService.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 769 48
PullMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 769 16
DefaultMappedFile.java
in store/src/main/java/org/apache/rocketmq/store/logfile
 753 71
DefaultMQProducer.java
in client/src/main/java/org/apache/rocketmq/client/producer
 741 118
MappedFileQueue.java
in store/src/main/java/org/apache/rocketmq/store
 739 51
DefaultMQPullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 724 70
BrokerStatsManager.java
in store/src/main/java/org/apache/rocketmq/store/stats
 698 66
ScheduleMessageService.java
in broker/src/main/java/org/apache/rocketmq/broker/schedule
 697 62
ReplicasManager.java
in broker/src/main/java/org/apache/rocketmq/broker/controller
 681 45
rmq.broker.logback.xml
in broker/src/main/resources
 664 -
NettyRemotingServer.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 658 59
RebalanceImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 651 27
UtilAll.java
in common/src/main/java/org/apache/rocketmq/common
 638 52
MQVersion.java
in common/src/main/java/org/apache/rocketmq/common
 633 2
TopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 624 41
PopReviveService.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 624 22
TransactionalMessageServiceImpl.java
in broker/src/main/java/org/apache/rocketmq/broker/transaction/queue
 616 30
MQClientAPIExt.java
in client/src/main/java/org/apache/rocketmq/client/impl/mqclient
 615 29
BrokerMetricsManager.java
in broker/src/main/java/org/apache/rocketmq/broker/metrics
 605 18
PopConsumerService.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 599 25
SendMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 593 12
TopicQueueMappingUtils.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic
 588 26
ReplicasInfoManager.java
in controller/src/main/java/org/apache/rocketmq/controller/impl/manager
 568 22
DefaultRequestProcessor.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/processor
 566 30
MessageDecoder.java
in common/src/main/java/org/apache/rocketmq/common/message
 565 22
AutoSwitchHAConnection.java
in store/src/main/java/org/apache/rocketmq/store/ha/autoswitch
 558 35
Files With Most Units (Top 50)
File# lines# units
BrokerConfig.java
in common/src/main/java/org/apache/rocketmq/common
 1424 399
MessageStoreConfig.java
in store/src/main/java/org/apache/rocketmq/store/config
 1348 364
ProxyConfig.java
in proxy/src/main/java/org/apache/rocketmq/proxy/config
 1136 305
DefaultMessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 2709 218
BrokerController.java
in broker/src/main/java/org/apache/rocketmq/broker
 2119 177
MQClientAPIImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 3092 145
DefaultMQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 820 143
DefaultMQAdminExtImpl.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 1791 142
DefaultMQProducer.java
in client/src/main/java/org/apache/rocketmq/client/producer
 741 118
AbstractPluginMessageStore.java
in store/src/main/java/org/apache/rocketmq/store/plugin
 531 115
CommitLog.java
in store/src/main/java/org/apache/rocketmq/store
 1970 114
DefaultMQPushConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 486 102
TimerMessageStore.java
in store/src/main/java/org/apache/rocketmq/store/timer
 1673 100
DefaultMQProducerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/producer
 1578 100
AdminBrokerProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 2976 97
DefaultLitePullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1071 92
DefaultMQPushConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1325 87
DefaultLitePullConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 378 84
MessageStoreConfig.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore
 290 75
DefaultMappedFile.java
in store/src/main/java/org/apache/rocketmq/store/logfile
 753 71
ClientConfig.java
in client/src/main/java/org/apache/rocketmq/client
 414 71
DefaultMQPullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 724 70
MQClientInstance.java
in client/src/main/java/org/apache/rocketmq/client/impl/factory
 1183 68
BatchConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store/queue
 949 66
BrokerStatsManager.java
in store/src/main/java/org/apache/rocketmq/store/stats
 698 66
RouteInfoManager.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo
 1071 66
DefaultMQPullConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 337 65
BrokerOuterAPI.java
in broker/src/main/java/org/apache/rocketmq/broker/out
 1271 63
CompactionLog.java
in store/src/main/java/org/apache/rocketmq/store/kv
 940 63
SendMessageContext.java
in broker/src/main/java/org/apache/rocketmq/broker/mqtrace
 230 62
ScheduleMessageService.java
in broker/src/main/java/org/apache/rocketmq/broker/schedule
 697 62
RemotingCommand.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 511 62
NettyRemotingClient.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 1064 60
ControllerConfig.java
in common/src/main/java/org/apache/rocketmq/common
 218 59
NettyRemotingServer.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 658 59
ConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store
 979 57
RocksDBConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store/queue
 366 53
AuthConfig.java
in auth/src/main/java/org/apache/rocketmq/auth/config
 193 53
UtilAll.java
in common/src/main/java/org/apache/rocketmq/common
 638 52
ComparisonExpression.java
in filter/src/main/java/org/apache/rocketmq/filter/expression
 494 51
MappedFileQueue.java
in store/src/main/java/org/apache/rocketmq/store
 739 51
DLedgerCommitLog.java
in store/src/main/java/org/apache/rocketmq/store/dledger
 910 50
PopBufferMergeService.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 769 48
ConsumeMessageContext.java
in broker/src/main/java/org/apache/rocketmq/broker/mqtrace
 174 46
ConsumerOrderInfoManager.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 484 45
ReplicasManager.java
in broker/src/main/java/org/apache/rocketmq/broker/controller
 681 45
ConsumeQueueStore.java
in store/src/main/java/org/apache/rocketmq/store/queue
 499 45
NettyLogger.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 287 45
NamesrvConfig.java
in common/src/main/java/org/apache/rocketmq/common/namesrv
 159 44
MessageExt.java
in common/src/main/java/org/apache/rocketmq/common/message
 217 44
Files With Long Lines (Top 50)

There are 478 files with lines longer than 120 characters. In total, there are 3896 long lines.

File# lines# units# long lines
MQClientAPIImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 3092 145 197
AdminBrokerProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 2976 97 179
DefaultMQAdminExtImpl.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 1791 142 136
DefaultMessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 2709 218 94
CommitLog.java
in store/src/main/java/org/apache/rocketmq/store
 1970 114 86
BrokerController.java
in broker/src/main/java/org/apache/rocketmq/broker
 2119 177 85
DefaultMQPushConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1325 87 71
BrokerOuterAPI.java
in broker/src/main/java/org/apache/rocketmq/broker/out
 1271 63 65
PullMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 769 16 48
ReplicasManager.java
in broker/src/main/java/org/apache/rocketmq/broker/controller
 681 45 47
DefaultMQProducerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/producer
 1578 100 46
PopMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 943 36 44
SendMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 593 12 43
PopReviveService.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 624 22 42
ReplicasInfoManager.java
in controller/src/main/java/org/apache/rocketmq/controller/impl/manager
 568 22 42
MqClientAdminImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/admin
 395 18 40
NettyRemotingClient.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 1064 60 40
MQClientInstance.java
in client/src/main/java/org/apache/rocketmq/client/impl/factory
 1183 68 39
RpcClientImpl.java
in remoting/src/main/java/org/apache/rocketmq/remoting/rpc
 287 15 39
TopicQueueMappingUtils.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic
 588 26 39
DefaultLitePullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1071 92 36
rmq.broker.logback.xml
in broker/src/main/resources
 664 - 35
MQAdminUtils.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 291 13 33
MQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 322 - 33
TimerMessageStore.java
in store/src/main/java/org/apache/rocketmq/store/timer
 1673 100 33
DefaultMQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 820 143 32
DLedgerCommitLog.java
in store/src/main/java/org/apache/rocketmq/store/dledger
 910 50 31
rmq.proxy.logback.xml
in proxy/src/main/resources
 403 - 31
ScheduleMessageService.java
in broker/src/main/java/org/apache/rocketmq/broker/schedule
 697 62 29
BrokerMetricsManager.java
in broker/src/main/java/org/apache/rocketmq/broker/metrics
 605 18 28
PeekMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 262 6 28
PopBufferMergeService.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 769 48 26
AutoSwitchHAConnection.java
in store/src/main/java/org/apache/rocketmq/store/ha/autoswitch
 558 35 26
ControllerManager.java
in controller/src/main/java/org/apache/rocketmq/controller
 306 27 26
DefaultMQPullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 724 70 25
ConsumeMessageOrderlyService.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 485 25 25
MQAdminImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 404 22 25
GrpcMessagingApplication.java
in proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2
 424 27 25
ControllerRequestProcessor.java
in controller/src/main/java/org/apache/rocketmq/controller/processor
 294 18 25
DefaultRequestProcessor.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/processor
 566 30 25
ChangeInvisibleTimeProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 307 10 24
EscapeBridge.java
in broker/src/main/java/org/apache/rocketmq/broker/failover
 335 14 24
BrokerStatsManager.java
in store/src/main/java/org/apache/rocketmq/store/stats
 698 66 24
ConsumerProcessor.java
in proxy/src/main/java/org/apache/rocketmq/proxy/processor
 499 15 24
AutoSwitchHAClient.java
in store/src/main/java/org/apache/rocketmq/store/ha/autoswitch
 443 26 23
JRaftControllerStateMachine.java
in controller/src/main/java/org/apache/rocketmq/controller/impl
 288 22 23
DLedgerController.java
in controller/src/main/java/org/apache/rocketmq/controller/impl
 479 37 23
SendMessageActivity.java
in proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer
 330 15 22
DefaultHAConnection.java
in store/src/main/java/org/apache/rocketmq/store/ha
 363 21 21
NettyRemotingServer.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 658 59 21
Correlations

File Size vs. Commits (all time): 1490 points

common/src/main/java/org/apache/rocketmq/common/MQVersion.java x: 71 commits (all time) y: 633 lines of code broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java x: 4 commits (all time) y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java x: 18 commits (all time) y: 484 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java x: 3 commits (all time) y: 146 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java x: 7 commits (all time) y: 599 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java x: 31 commits (all time) y: 416 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java x: 185 commits (all time) y: 2976 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java x: 28 commits (all time) y: 307 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java x: 31 commits (all time) y: 769 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java x: 81 commits (all time) y: 943 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java x: 50 commits (all time) y: 624 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java x: 12 commits (all time) y: 204 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java x: 3 commits (all time) y: 207 lines of code store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java x: 15 commits (all time) y: 148 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java x: 5 commits (all time) y: 132 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java x: 6 commits (all time) y: 208 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java x: 6 commits (all time) y: 227 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java x: 8 commits (all time) y: 367 lines of code client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java x: 66 commits (all time) y: 351 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/AuthMigrator.java x: 3 commits (all time) y: 191 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AccessResource.java x: 1 commits (all time) y: 3 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AclConfig.java x: 1 commits (all time) y: 25 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessConfig.java x: 1 commits (all time) y: 86 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessData.java x: 1 commits (all time) y: 68 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessResource.java x: 1 commits (all time) y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java x: 242 commits (all time) y: 2119 lines of code client/src/main/java/org/apache/rocketmq/acl/common/AclException.java x: 1 commits (all time) y: 39 lines of code client/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java x: 1 commits (all time) y: 229 lines of code client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java x: 1 commits (all time) y: 122 lines of code client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java x: 187 commits (all time) y: 3092 lines of code common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java x: 166 commits (all time) y: 1424 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java x: 46 commits (all time) y: 194 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java x: 73 commits (all time) y: 1136 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java x: 26 commits (all time) y: 77 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java x: 17 commits (all time) y: 320 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/AuthenticationPipeline.java x: 5 commits (all time) y: 40 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java x: 19 commits (all time) y: 161 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/ResponseCode.java x: 9 commits (all time) y: 64 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java x: 102 commits (all time) y: 820 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java x: 133 commits (all time) y: 1791 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java x: 87 commits (all time) y: 322 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java x: 116 commits (all time) y: 280 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java x: 4 commits (all time) y: 53 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java x: 7 commits (all time) y: 354 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java x: 38 commits (all time) y: 357 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java x: 15 commits (all time) y: 256 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java x: 39 commits (all time) y: 355 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java x: 6 commits (all time) y: 411 lines of code store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java x: 249 commits (all time) y: 2709 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java x: 8 commits (all time) y: 145 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelAttributeHelper.java x: 1 commits (all time) y: 51 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java x: 45 commits (all time) y: 282 lines of code client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java x: 24 commits (all time) y: 65 lines of code client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java x: 140 commits (all time) y: 1183 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java x: 23 commits (all time) y: 133 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java x: 10 commits (all time) y: 139 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsHelper.java x: 14 commits (all time) y: 178 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java x: 72 commits (all time) y: 495 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java x: 26 commits (all time) y: 122 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/TopicStatsTable.java x: 2 commits (all time) y: 21 lines of code store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java x: 42 commits (all time) y: 698 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java x: 15 commits (all time) y: 91 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java x: 43 commits (all time) y: 438 lines of code broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java x: 3 commits (all time) y: 195 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java x: 73 commits (all time) y: 769 lines of code broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java x: 39 commits (all time) y: 321 lines of code common/src/main/java/org/apache/rocketmq/common/MixAll.java x: 121 commits (all time) y: 473 lines of code store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java x: 20 commits (all time) y: 139 lines of code common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItem.java x: 15 commits (all time) y: 54 lines of code common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java x: 26 commits (all time) y: 101 lines of code common/src/main/java/org/apache/rocketmq/common/stats/StatsItem.java x: 24 commits (all time) y: 206 lines of code common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java x: 30 commits (all time) y: 225 lines of code store/src/main/java/org/apache/rocketmq/store/CommitLog.java x: 170 commits (all time) y: 1970 lines of code store/src/main/java/org/apache/rocketmq/store/index/IndexService.java x: 29 commits (all time) y: 321 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java x: 19 commits (all time) y: 266 lines of code store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java x: 87 commits (all time) y: 910 lines of code store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueStore.java x: 10 commits (all time) y: 444 lines of code broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java x: 30 commits (all time) y: 697 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerContext.java x: 2 commits (all time) y: 125 lines of code client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java x: 160 commits (all time) y: 1578 lines of code client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java x: 112 commits (all time) y: 741 lines of code example/src/main/java/org/apache/rocketmq/example/simple/PopConsumer.java x: 2 commits (all time) y: 45 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java x: 40 commits (all time) y: 1673 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerPathConfigHelper.java x: 23 commits (all time) y: 48 lines of code broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerLagCalculator.java x: 15 commits (all time) y: 444 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java x: 27 commits (all time) y: 189 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/NotifyResult.java x: 1 commits (all time) y: 23 lines of code client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java x: 10 commits (all time) y: 615 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java x: 21 commits (all time) y: 410 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreFetcherImpl.java x: 8 commits (all time) y: 378 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java x: 28 commits (all time) y: 248 lines of code broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java x: 38 commits (all time) y: 219 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java x: 78 commits (all time) y: 624 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java x: 119 commits (all time) y: 1064 lines of code container/src/main/java/org/apache/rocketmq/container/InnerBrokerController.java x: 17 commits (all time) y: 143 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java x: 27 commits (all time) y: 166 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManagerFactory.java x: 6 commits (all time) y: 22 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java x: 88 commits (all time) y: 552 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java x: 82 commits (all time) y: 658 lines of code filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParser.java x: 13 commits (all time) y: 429 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java x: 17 commits (all time) y: 75 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ExportRocksDBConfigToJsonRequestHeader.java x: 2 commits (all time) y: 69 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumeStatsRequestHeader.java x: 4 commits (all time) y: 67 lines of code store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java x: 17 commits (all time) y: 367 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/AckMessageActivity.java x: 21 commits (all time) y: 174 lines of code common/src/main/java/org/apache/rocketmq/common/config/AbstractRocksDBStorage.java x: 13 commits (all time) y: 495 lines of code store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueOffsetTable.java x: 4 commits (all time) y: 555 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataInRocksDBCommand.java x: 5 commits (all time) y: 108 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/metadata/RocksDBConfigToJsonCommand.java x: 6 commits (all time) y: 271 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerKVStore.java x: 2 commits (all time) y: 10 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java x: 3 commits (all time) y: 129 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java x: 46 commits (all time) y: 616 lines of code broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopLongPollingService.java x: 6 commits (all time) y: 356 lines of code store/src/main/java/org/apache/rocketmq/store/rocksdb/RocksDBOptionsFactory.java x: 6 commits (all time) y: 186 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/RecallMessageProcessor.java x: 2 commits (all time) y: 157 lines of code common/src/main/java/org/apache/rocketmq/common/message/Message.java x: 32 commits (all time) y: 191 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/ProducerProcessor.java x: 28 commits (all time) y: 224 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/SendMessageActivity.java x: 5 commits (all time) y: 71 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreDispatcherImpl.java x: 5 commits (all time) y: 324 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatFileInterface.java x: 3 commits (all time) y: 40 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java x: 56 commits (all time) y: 651 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerCache.java x: 1 commits (all time) y: 242 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportPopRecordCommand.java x: 1 commits (all time) y: 82 lines of code auth/src/main/java/org/apache/rocketmq/auth/authorization/builder/DefaultAuthorizationContextBuilder.java x: 6 commits (all time) y: 465 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java x: 105 commits (all time) y: 1325 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java x: 29 commits (all time) y: 256 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java x: 35 commits (all time) y: 299 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java x: 9 commits (all time) y: 90 lines of code store/src/main/java/org/apache/rocketmq/store/MessageStore.java x: 65 commits (all time) y: 166 lines of code store/src/main/java/org/apache/rocketmq/store/plugin/AbstractPluginMessageStore.java x: 14 commits (all time) y: 531 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java x: 116 commits (all time) y: 593 lines of code client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java x: 26 commits (all time) y: 87 lines of code client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java x: 14 commits (all time) y: 107 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java x: 31 commits (all time) y: 211 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceType.java x: 11 commits (all time) y: 8 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/RequestMapping.java x: 7 commits (all time) y: 38 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/DefaultGrpcMessingActivity.java x: 25 commits (all time) y: 128 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java x: 28 commits (all time) y: 424 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessingActivity.java x: 10 commits (all time) y: 46 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java x: 32 commits (all time) y: 330 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java x: 40 commits (all time) y: 307 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/MessagingProcessor.java x: 33 commits (all time) y: 284 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/message/ClusterMessageService.java x: 25 commits (all time) y: 244 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalMessageService.java x: 33 commits (all time) y: 467 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/message/MessageService.java x: 18 commits (all time) y: 135 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageResponseHeader.java x: 2 commits (all time) y: 93 lines of code srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java x: 22 commits (all time) y: 73 lines of code store/src/main/java/org/apache/rocketmq/store/stats/LmqBrokerStatsManager.java x: 5 commits (all time) y: 54 lines of code store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java x: 118 commits (all time) y: 1348 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java x: 42 commits (all time) y: 388 lines of code client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java x: 2 commits (all time) y: 454 lines of code client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java x: 7 commits (all time) y: 63 lines of code common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java x: 67 commits (all time) y: 565 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConfigStorage.java x: 4 commits (all time) y: 191 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConsumerOffsetManagerV2.java x: 3 commits (all time) y: 320 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java x: 4 commits (all time) y: 142 lines of code common/src/main/java/org/apache/rocketmq/common/config/ConfigHelper.java x: 3 commits (all time) y: 104 lines of code common/src/main/java/org/apache/rocketmq/common/config/ConfigRocksDBStorage.java x: 7 commits (all time) y: 106 lines of code container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java x: 19 commits (all time) y: 250 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java x: 55 commits (all time) y: 337 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java x: 76 commits (all time) y: 724 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java x: 25 commits (all time) y: 227 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/FileSegment.java x: 2 commits (all time) y: 271 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/MemoryFileSegment.java x: 2 commits (all time) y: 79 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ProxyTopicRouteData.java x: 10 commits (all time) y: 116 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroup.java x: 13 commits (all time) y: 280 lines of code broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotifyMessageArrivingListener.java x: 17 commits (all time) y: 25 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java x: 52 commits (all time) y: 511 lines of code store/src/main/java/org/apache/rocketmq/store/queue/AbstractConsumeQueueStore.java x: 4 commits (all time) y: 88 lines of code store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueue.java x: 5 commits (all time) y: 366 lines of code common/src/main/java/org/apache/rocketmq/common/constant/PermName.java x: 19 commits (all time) y: 45 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java x: 21 commits (all time) y: 268 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java x: 49 commits (all time) y: 309 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java x: 31 commits (all time) y: 146 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolTlsHelper.java x: 3 commits (all time) y: 83 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java x: 99 commits (all time) y: 1071 lines of code store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java x: 27 commits (all time) y: 288 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CheckRocksdbCqWriteProgressRequestHeader.java x: 2 commits (all time) y: 31 lines of code store/src/main/java/org/apache/rocketmq/store/RocksDBMessageStore.java x: 6 commits (all time) y: 146 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/LanguageCode.java x: 13 commits (all time) y: 40 lines of code store/src/main/java/org/apache/rocketmq/store/lock/AdaptiveBackOffSpinLockImpl.java x: 1 commits (all time) y: 143 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyLogger.java x: 11 commits (all time) y: 287 lines of code broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java x: 12 commits (all time) y: 43 lines of code broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java x: 33 commits (all time) y: 165 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/BroadcastOffsetManager.java x: 3 commits (all time) y: 159 lines of code common/src/main/java/org/apache/rocketmq/common/ServiceThread.java x: 32 commits (all time) y: 96 lines of code common/src/main/java/org/apache/rocketmq/common/message/MessageExtBrokerInner.java x: 10 commits (all time) y: 71 lines of code store/src/main/java/org/apache/rocketmq/store/AppendMessageStatus.java x: 7 commits (all time) y: 9 lines of code store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java x: 86 commits (all time) y: 979 lines of code store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java x: 21 commits (all time) y: 202 lines of code store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java x: 9 commits (all time) y: 287 lines of code store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java x: 25 commits (all time) y: 499 lines of code store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStoreInterface.java x: 3 commits (all time) y: 52 lines of code store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueTable.java x: 4 commits (all time) y: 291 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metrics/TieredStoreMetricsManager.java x: 10 commits (all time) y: 281 lines of code common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledIncrementPrinter.java x: 7 commits (all time) y: 209 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicQueueMappingUtils.java x: 4 commits (all time) y: 588 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerLog.java x: 8 commits (all time) y: 90 lines of code broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java x: 20 commits (all time) y: 335 lines of code broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java x: 68 commits (all time) y: 681 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java x: 6 commits (all time) y: 100 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java x: 36 commits (all time) y: 303 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/HeaderInterceptor.java x: 12 commits (all time) y: 66 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/pipeline/AuthenticationPipeline.java x: 2 commits (all time) y: 53 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java x: 19 commits (all time) y: 152 lines of code common/src/main/java/org/apache/rocketmq/common/utils/ServiceProvider.java x: 15 commits (all time) y: 139 lines of code store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java x: 40 commits (all time) y: 262 lines of code store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java x: 8 commits (all time) y: 305 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java x: 41 commits (all time) y: 479 lines of code store/src/main/java/org/apache/rocketmq/store/queue/CqUnit.java x: 5 commits (all time) y: 75 lines of code broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java x: 4 commits (all time) y: 33 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java x: 87 commits (all time) y: 486 lines of code client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java x: 55 commits (all time) y: 404 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java x: 41 commits (all time) y: 309 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java x: 32 commits (all time) y: 265 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java x: 14 commits (all time) y: 87 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommand.java x: 26 commits (all time) y: 169 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java x: 20 commits (all time) y: 132 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeOldCommand.java x: 11 commits (all time) y: 105 lines of code common/src/main/java/org/apache/rocketmq/common/utils/NetworkUtil.java x: 8 commits (all time) y: 171 lines of code common/src/main/java/org/apache/rocketmq/common/ConfigManager.java x: 21 commits (all time) y: 66 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/receipt/DefaultReceiptHandleManager.java x: 6 commits (all time) y: 246 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceBean.java x: 11 commits (all time) y: 113 lines of code common/src/main/java/org/apache/rocketmq/common/UtilAll.java x: 84 commits (all time) y: 638 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ClientManagerActivity.java x: 7 commits (all time) y: 165 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/MessageStoreConfig.java x: 2 commits (all time) y: 290 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexService.java x: 3 commits (all time) y: 15 lines of code broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java x: 106 commits (all time) y: 1271 lines of code common/src/main/java/org/apache/rocketmq/common/stats/Stats.java x: 5 commits (all time) y: 31 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java x: 16 commits (all time) y: 396 lines of code client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java x: 12 commits (all time) y: 86 lines of code client/src/main/java/org/apache/rocketmq/client/ClientConfig.java x: 71 commits (all time) y: 414 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java x: 53 commits (all time) y: 378 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/RaftBrokerHeartBeatManager.java x: 2 commits (all time) y: 230 lines of code store/src/main/java/org/apache/rocketmq/store/logfile/DefaultMappedFile.java x: 23 commits (all time) y: 753 lines of code store/src/main/java/org/apache/rocketmq/store/queue/BatchConsumeQueue.java x: 25 commits (all time) y: 949 lines of code store/src/main/java/org/apache/rocketmq/store/queue/SparseConsumeQueue.java x: 4 commits (all time) y: 321 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceConstants.java x: 19 commits (all time) y: 25 lines of code client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionOpenTracingHookImpl.java x: 6 commits (all time) y: 48 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/ConsumerProcessor.java x: 28 commits (all time) y: 499 lines of code broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java x: 37 commits (all time) y: 128 lines of code common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolMonitor.java x: 12 commits (all time) y: 101 lines of code proxy/src/main/resources/rmq.proxy.logback.xml x: 9 commits (all time) y: 403 lines of code broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsConstant.java x: 8 commits (all time) y: 43 lines of code broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsManager.java x: 25 commits (all time) y: 605 lines of code example/src/main/java/org/apache/rocketmq/example/operation/Consumer.java x: 8 commits (all time) y: 79 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/BatchProducer.java x: 21 commits (all time) y: 360 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/Producer.java x: 48 commits (all time) y: 369 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java x: 65 commits (all time) y: 485 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java x: 37 commits (all time) y: 235 lines of code client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java x: 21 commits (all time) y: 254 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java x: 27 commits (all time) y: 146 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePullImpl.java x: 20 commits (all time) y: 74 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java x: 22 commits (all time) y: 29 lines of code auth/src/main/java/org/apache/rocketmq/auth/authentication/builder/DefaultAuthenticationContextBuilder.java x: 2 commits (all time) y: 105 lines of code client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java x: 52 commits (all time) y: 245 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java x: 56 commits (all time) y: 386 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopOrderlyService.java x: 14 commits (all time) y: 334 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java x: 25 commits (all time) y: 57 lines of code client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java x: 19 commits (all time) y: 111 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/ClusterMetadataService.java x: 18 commits (all time) y: 237 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteService.java x: 26 commits (all time) y: 187 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java x: 5 commits (all time) y: 171 lines of code auth/src/main/java/org/apache/rocketmq/auth/authorization/manager/AuthorizationMetadataManagerImpl.java x: 2 commits (all time) y: 238 lines of code auth/src/main/java/org/apache/rocketmq/auth/authentication/provider/LocalAuthenticationMetadataProvider.java x: 2 commits (all time) y: 135 lines of code auth/src/main/java/org/apache/rocketmq/auth/authorization/provider/LocalAuthorizationMetadataProvider.java x: 2 commits (all time) y: 167 lines of code auth/src/main/java/org/apache/rocketmq/auth/config/AuthConfig.java x: 1 commits (all time) y: 193 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java x: 62 commits (all time) y: 252 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java x: 31 commits (all time) y: 81 lines of code broker/src/main/resources/rmq.broker.logback.xml x: 13 commits (all time) y: 664 lines of code client/src/main/java/org/apache/rocketmq/client/MQAdmin.java x: 19 commits (all time) y: 21 lines of code common/src/main/java/org/apache/rocketmq/common/Pair.java x: 8 commits (all time) y: 25 lines of code common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java x: 43 commits (all time) y: 40 lines of code container/src/main/java/org/apache/rocketmq/container/BrokerContainer.java x: 20 commits (all time) y: 384 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/ProxyAndTlsProtocolNegotiator.java x: 6 commits (all time) y: 233 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/ContextInterceptor.java x: 9 commits (all time) y: 19 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/transaction/EndTransactionActivity.java x: 14 commits (all time) y: 57 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionProcessor.java x: 10 commits (all time) y: 55 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannel.java x: 7 commits (all time) y: 222 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java x: 10 commits (all time) y: 17 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/LocalMetadataService.java x: 10 commits (all time) y: 36 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/AbstractProxyRelayService.java x: 9 commits (all time) y: 42 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/AbstractTransactionService.java x: 14 commits (all time) y: 65 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionData.java x: 7 commits (all time) y: 85 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/RemotingService.java x: 8 commits (all time) y: 9 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSerializable.java x: 21 commits (all time) y: 55 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ConsumeMessageDirectlyResultRequestHeader.java x: 3 commits (all time) y: 87 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CreateTopicRequestHeader.java x: 3 commits (all time) y: 120 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/DeleteSubscriptionGroupRequestHeader.java x: 3 commits (all time) y: 31 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PullMessageRequestHeader.java x: 2 commits (all time) y: 255 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryConsumerOffsetRequestHeader.java x: 3 commits (all time) y: 62 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeaderV2.java x: 4 commits (all time) y: 274 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/ElectMasterRequestHeader.java x: 7 commits (all time) y: 87 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/register/GetNextBrokerIdRequestHeader.java x: 4 commits (all time) y: 42 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/BrokerHeartbeatRequestHeader.java x: 5 commits (all time) y: 89 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/auth/CreateAclSubCommand.java x: 1 commits (all time) y: 105 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java x: 94 commits (all time) y: 1071 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/AppendResult.java x: 3 commits (all time) y: 8 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/stream/CommitLogInputStream.java x: 1 commits (all time) y: 151 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java x: 55 commits (all time) y: 188 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java x: 22 commits (all time) y: 212 lines of code common/src/main/java/org/apache/rocketmq/common/namesrv/DefaultTopAddressing.java x: 10 commits (all time) y: 128 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ClusterTopicRouteService.java x: 12 commits (all time) y: 32 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/route/LocalTopicRouteService.java x: 13 commits (all time) y: 65 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java x: 45 commits (all time) y: 297 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java x: 4 commits (all time) y: 180 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java x: 26 commits (all time) y: 235 lines of code broker/src/main/java/org/apache/rocketmq/broker/plugin/PullMessageResultHandler.java x: 7 commits (all time) y: 22 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/DefaultPullMessageResultHandler.java x: 17 commits (all time) y: 246 lines of code common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java x: 13 commits (all time) y: 218 lines of code controller/src/main/java/org/apache/rocketmq/controller/BrokerHeartbeatManager.java x: 16 commits (all time) y: 29 lines of code controller/src/main/java/org/apache/rocketmq/controller/ControllerManager.java x: 36 commits (all time) y: 306 lines of code controller/src/main/java/org/apache/rocketmq/controller/ControllerStartup.java x: 13 commits (all time) y: 120 lines of code controller/src/main/java/org/apache/rocketmq/controller/elect/ElectPolicy.java x: 4 commits (all time) y: 6 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/JRaftControllerStateMachine.java x: 1 commits (all time) y: 288 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/BrokerLiveInfo.java x: 2 commits (all time) y: 113 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/manager/RaftReplicasInfoManager.java x: 1 commits (all time) y: 201 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManager.java x: 46 commits (all time) y: 568 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/manager/SyncStateInfo.java x: 12 commits (all time) y: 56 lines of code controller/src/main/java/org/apache/rocketmq/controller/metrics/ControllerMetricsManager.java x: 4 commits (all time) y: 311 lines of code controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java x: 34 commits (all time) y: 294 lines of code controller/src/main/resources/rmq.controller.logback.xml x: 9 commits (all time) y: 152 lines of code example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java x: 23 commits (all time) y: 31 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java x: 68 commits (all time) y: 566 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java x: 17 commits (all time) y: 13 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java x: 13 commits (all time) y: 97 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolRemotingServer.java x: 8 commits (all time) y: 58 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageService.java x: 11 commits (all time) y: 18 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/DefaultTransactionalMessageCheckListener.java x: 16 commits (all time) y: 58 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/metrics/RemotingMetricsConstant.java x: 4 commits (all time) y: 15 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingCleanService.java x: 13 commits (all time) y: 297 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java x: 45 commits (all time) y: 206 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java x: 53 commits (all time) y: 319 lines of code client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java x: 35 commits (all time) y: 99 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/TransactionProducer.java x: 39 commits (all time) y: 399 lines of code example/src/main/java/org/apache/rocketmq/example/namespace/ProducerWithNamespace.java x: 15 commits (all time) y: 29 lines of code example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java x: 16 commits (all time) y: 21 lines of code example/src/main/java/org/apache/rocketmq/example/tracemessage/TraceProducer.java x: 14 commits (all time) y: 33 lines of code example/src/main/java/org/apache/rocketmq/example/tracemessage/TracePushConsumer.java x: 15 commits (all time) y: 23 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManager.java x: 29 commits (all time) y: 204 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java x: 20 commits (all time) y: 194 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcValidator.java x: 11 commits (all time) y: 94 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ChangeInvisibleDurationActivity.java x: 19 commits (all time) y: 59 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity.java x: 37 commits (all time) y: 162 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageResponseStreamWriter.java x: 14 commits (all time) y: 131 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/ReceiptHandleProcessor.java x: 38 commits (all time) y: 44 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyChannel.java x: 20 commits (all time) y: 155 lines of code common/src/main/java/org/apache/rocketmq/common/consumer/ReceiptHandle.java x: 11 commits (all time) y: 184 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ExtraInfoUtil.java x: 4 commits (all time) y: 261 lines of code common/src/main/java/org/apache/rocketmq/common/utils/BinaryUtil.java x: 7 commits (all time) y: 36 lines of code client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceService.java x: 14 commits (all time) y: 40 lines of code store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java x: 53 commits (all time) y: 739 lines of code common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java x: 24 commits (all time) y: 159 lines of code container/src/main/java/org/apache/rocketmq/container/BrokerContainerConfig.java x: 11 commits (all time) y: 70 lines of code broker/src/main/java/org/apache/rocketmq/broker/filter/ExpressionForRetryMessageFilter.java x: 7 commits (all time) y: 59 lines of code tools/src/main/java/org/apache/rocketmq/tools/monitor/MonitorService.java x: 20 commits (all time) y: 261 lines of code example/src/main/java/org/apache/rocketmq/example/transaction/TransactionProducer.java x: 15 commits (all time) y: 48 lines of code common/src/main/java/org/apache/rocketmq/common/message/MessageConst.java x: 45 commits (all time) y: 123 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java x: 25 commits (all time) y: 65 lines of code container/src/main/java/org/apache/rocketmq/container/ContainerClientHouseKeepingService.java x: 6 commits (all time) y: 72 lines of code controller/src/main/java/org/apache/rocketmq/controller/BrokerHousekeepingService.java x: 9 commits (all time) y: 31 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java x: 13 commits (all time) y: 28 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/ChannelEventListener.java x: 6 commits (all time) y: 9 lines of code example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java x: 23 commits (all time) y: 102 lines of code common/src/main/java/org/apache/rocketmq/common/topic/TopicValidator.java x: 13 commits (all time) y: 106 lines of code store/src/main/java/org/apache/rocketmq/store/CommitLogDispatcher.java x: 5 commits (all time) y: 5 lines of code store/src/main/java/org/apache/rocketmq/store/ha/HAService.java x: 65 commits (all time) y: 39 lines of code store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAClient.java x: 32 commits (all time) y: 443 lines of code store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java x: 52 commits (all time) y: 456 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncer.java x: 9 commits (all time) y: 203 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/RemotingClient.java x: 22 commits (all time) y: 53 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/ResponseFuture.java x: 13 commits (all time) y: 125 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java x: 27 commits (all time) y: 30 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerRequest.java x: 6 commits (all time) y: 88 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/metrics/ProxyMetricsManager.java x: 11 commits (all time) y: 215 lines of code broker/src/main/java/org/apache/rocketmq/broker/dledger/DLedgerRoleChangeHandler.java x: 25 commits (all time) y: 145 lines of code common/src/main/java/org/apache/rocketmq/common/utils/ThreadUtils.java x: 13 commits (all time) y: 139 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java x: 37 commits (all time) y: 216 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java x: 17 commits (all time) y: 95 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/LocalServiceManager.java x: 15 commits (all time) y: 111 lines of code store/src/main/java/org/apache/rocketmq/store/kv/CompactionStore.java x: 11 commits (all time) y: 195 lines of code client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java x: 29 commits (all time) y: 131 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueView.java x: 11 commits (all time) y: 41 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueSelector.java x: 13 commits (all time) y: 253 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/processor/AbstractProcessor.java x: 12 commits (all time) y: 21 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java x: 18 commits (all time) y: 128 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerStatusSubCommand.java x: 11 commits (all time) y: 82 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java x: 18 commits (all time) y: 101 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java x: 12 commits (all time) y: 82 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java x: 31 commits (all time) y: 158 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java x: 13 commits (all time) y: 74 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java x: 20 commits (all time) y: 121 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java x: 17 commits (all time) y: 161 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/controller/CleanControllerBrokerMetaSubCommand.java x: 4 commits (all time) y: 75 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/controller/GetControllerMetaDataSubCommand.java x: 6 commits (all time) y: 52 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java x: 7 commits (all time) y: 134 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java x: 10 commits (all time) y: 103 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java x: 16 commits (all time) y: 104 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java x: 10 commits (all time) y: 243 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageByQueueCommand.java x: 15 commits (all time) y: 199 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByOffsetSubCommand.java x: 9 commits (all time) y: 83 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/WipeWritePermSubCommand.java x: 9 commits (all time) y: 58 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/AllocateMQSubCommand.java x: 8 commits (all time) y: 66 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java x: 23 commits (all time) y: 81 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java x: 10 commits (all time) y: 74 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateStaticTopicSubCommand.java x: 10 commits (all time) y: 155 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java x: 29 commits (all time) y: 147 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java x: 25 commits (all time) y: 193 lines of code example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java x: 18 commits (all time) y: 22 lines of code store/src/main/java/org/apache/rocketmq/store/timer/Slot.java x: 5 commits (all time) y: 23 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java x: 5 commits (all time) y: 142 lines of code client/src/main/java/org/apache/rocketmq/client/trace/hook/ConsumeMessageTraceHookImpl.java x: 18 commits (all time) y: 89 lines of code filter/src/main/java/org/apache/rocketmq/filter/expression/ComparisonExpression.java x: 10 commits (all time) y: 494 lines of code filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParserTokenManager.java x: 6 commits (all time) y: 973 lines of code filter/src/main/java/org/apache/rocketmq/filter/parser/SimpleCharStream.java x: 12 commits (all time) y: 304 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java x: 33 commits (all time) y: 237 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/Consumer.java x: 51 commits (all time) y: 235 lines of code client/src/main/java/org/apache/rocketmq/client/Validators.java x: 30 commits (all time) y: 92 lines of code openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/PushConsumerImpl.java x: 8 commits (all time) y: 162 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManager.java x: 13 commits (all time) y: 20 lines of code store/src/main/java/org/apache/rocketmq/store/StoreCheckpoint.java x: 19 commits (all time) y: 107 lines of code store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java x: 36 commits (all time) y: 558 lines of code client/src/main/java/org/apache/rocketmq/client/impl/admin/MqClientAdminImpl.java x: 1 commits (all time) y: 395 lines of code store/src/main/java/org/apache/rocketmq/store/AppendMessageCallback.java x: 20 commits (all time) y: 10 lines of code store/src/main/java/org/apache/rocketmq/store/kv/CompactionLog.java x: 7 commits (all time) y: 940 lines of code example/src/main/java/org/apache/rocketmq/example/simple/PushConsumer.java x: 18 commits (all time) y: 29 lines of code controller/src/main/java/org/apache/rocketmq/controller/Controller.java x: 20 commits (all time) y: 33 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageUtil.java x: 15 commits (all time) y: 63 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BrokerReplicasInfo.java x: 5 commits (all time) y: 148 lines of code store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java x: 36 commits (all time) y: 186 lines of code store/src/main/java/org/apache/rocketmq/store/index/IndexHeader.java x: 15 commits (all time) y: 84 lines of code common/src/main/java/org/apache/rocketmq/common/message/MessageType.java x: 8 commits (all time) y: 23 lines of code store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAClient.java x: 14 commits (all time) y: 312 lines of code store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAConnection.java x: 17 commits (all time) y: 363 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyDecoder.java x: 21 commits (all time) y: 40 lines of code store/src/main/java/org/apache/rocketmq/store/stats/BrokerStats.java x: 23 commits (all time) y: 56 lines of code common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java x: 22 commits (all time) y: 121 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java x: 32 commits (all time) y: 310 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminUtils.java x: 6 commits (all time) y: 291 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RocketMQSerializable.java x: 18 commits (all time) y: 171 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java x: 22 commits (all time) y: 43 lines of code distribution/release.xml x: 36 commits (all time) y: 92 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerData.java x: 4 commits (all time) y: 130 lines of code common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java x: 17 commits (all time) y: 57 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerPreOnlineService.java x: 11 commits (all time) y: 233 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageCheckService.java x: 24 commits (all time) y: 38 lines of code container/src/main/java/org/apache/rocketmq/container/BrokerContainerStartup.java x: 18 commits (all time) y: 343 lines of code store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java x: 38 commits (all time) y: 536 lines of code broker/src/main/java/org/apache/rocketmq/broker/filter/ConsumerFilterManager.java x: 18 commits (all time) y: 354 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AbstractAllocateMessageQueueStrategy.java x: 11 commits (all time) y: 31 lines of code client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java x: 21 commits (all time) y: 25 lines of code example/src/main/java/org/apache/rocketmq/example/benchmark/timer/TimerProducer.java x: 8 commits (all time) y: 249 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java x: 26 commits (all time) y: 157 lines of code openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/LocalMessageCache.java x: 15 commits (all time) y: 176 lines of code openmessaging/src/main/java/io/openmessaging/rocketmq/producer/ProducerImpl.java x: 8 commits (all time) y: 112 lines of code openmessaging/src/main/java/io/openmessaging/rocketmq/utils/BeanUtils.java x: 17 commits (all time) y: 126 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/Configuration.java x: 4 commits (all time) y: 243 lines of code store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/EpochFileCache.java x: 10 commits (all time) y: 264 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerCheckpoint.java x: 9 commits (all time) y: 141 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteHelper.java x: 6 commits (all time) y: 26 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumerRunningInfo.java x: 1 commits (all time) y: 273 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/TopicRouteData.java x: 1 commits (all time) y: 175 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/CommandUtil.java x: 26 commits (all time) y: 143 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/queue/QueryConsumeQueueCommand.java x: 12 commits (all time) y: 112 lines of code dev/merge_rocketmq_pr.py x: 7 commits (all time) y: 298 lines of code store/src/main/java/org/apache/rocketmq/store/AppendMessageResult.java x: 17 commits (all time) y: 120 lines of code example/src/main/java/org/apache/rocketmq/example/operation/Producer.java x: 6 commits (all time) y: 78 lines of code client/src/main/java/org/apache/rocketmq/client/trace/TraceView.java x: 8 commits (all time) y: 131 lines of code common/src/main/java/org/apache/rocketmq/common/filter/impl/PolishExpr.java x: 9 commits (all time) y: 126 lines of code example/src/main/java/org/apache/rocketmq/example/simple/AclClient.java x: 15 commits (all time) y: 128 lines of code filter/src/main/java/org/apache/rocketmq/filter/expression/UnaryExpression.java x: 8 commits (all time) y: 192 lines of code example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java x: 16 commits (all time) y: 37 lines of code example/src/main/java/org/apache/rocketmq/example/openmessaging/SimpleProducer.java x: 13 commits (all time) y: 50 lines of code example/src/main/java/org/apache/rocketmq/example/rpc/ResponseConsumer.java x: 18 commits (all time) y: 52 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/broker/SendMsgStatusCommand.java x: 17 commits (all time) y: 66 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java x: 11 commits (all time) y: 51 lines of code style/rmq_codeStyle.xml x: 6 commits (all time) y: 126 lines of code broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java x: 13 commits (all time) y: 230 lines of code broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java x: 18 commits (all time) y: 68 lines of code common/src/main/java/org/apache/rocketmq/common/TopicConfig.java x: 19 commits (all time) y: 207 lines of code common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java x: 26 commits (all time) y: 217 lines of code common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java x: 15 commits (all time) y: 5 lines of code common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItem.java x: 4 commits (all time) y: 108 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyExceptionCode.java x: 14 commits (all time) y: 9 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java x: 12 commits (all time) y: 5 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannelHandlerContext.java x: 5 commits (all time) y: 184 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/RPCHook.java x: 9 commits (all time) y: 7 lines of code store/src/main/java/org/apache/rocketmq/store/ha/HAConnection.java x: 33 commits (all time) y: 13 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/consumer/DeleteSubscriptionGroupCommand.java x: 16 commits (all time) y: 83 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java x: 19 commits (all time) y: 70 lines of code controller/src/main/java/org/apache/rocketmq/controller/impl/DledgerController.java x: 3 commits (all time) y: 479 lines of code client/src/main/java/org/apache/rocketmq/client/producer/TransactionCheckListener.java x: 13 commits (all time) y: 6 lines of code broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java x: 14 commits (all time) y: 79 lines of code client/src/main/java/org/apache/rocketmq/client/hook/SendMessageContext.java x: 9 commits (all time) y: 101 lines of code filter/src/main/java/org/apache/rocketmq/filter/util/BitsArray.java x: 2 commits (all time) y: 186 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 249.0
commits (all time)
min: 1.0 | average: 11.01 | 25th percentile: 2.0 | median: 5.0 | 75th percentile: 12.0 | max: 249.0

File Size vs. Contributors (all time): 1490 points

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

File Size vs. Commits (30 days): 65 points

common/src/main/java/org/apache/rocketmq/common/MQVersion.java x: 1 commits (30d) y: 633 lines of code broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java x: 2 commits (30d) y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java x: 2 commits (30d) y: 484 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java x: 2 commits (30d) y: 146 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java x: 3 commits (30d) y: 599 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java x: 2 commits (30d) y: 416 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java x: 5 commits (30d) y: 2976 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java x: 2 commits (30d) y: 307 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java x: 2 commits (30d) y: 769 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java x: 3 commits (30d) y: 943 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java x: 2 commits (30d) y: 624 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java x: 2 commits (30d) y: 204 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java x: 2 commits (30d) y: 207 lines of code store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java x: 2 commits (30d) y: 148 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java x: 2 commits (30d) y: 132 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java x: 2 commits (30d) y: 227 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java x: 2 commits (30d) y: 367 lines of code client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java x: 2 commits (30d) y: 351 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/AuthMigrator.java x: 1 commits (30d) y: 191 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AccessResource.java x: 1 commits (30d) y: 3 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AclConfig.java x: 1 commits (30d) y: 25 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessConfig.java x: 1 commits (30d) y: 86 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessData.java x: 1 commits (30d) y: 68 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessResource.java x: 1 commits (30d) y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java x: 4 commits (30d) y: 2119 lines of code client/src/main/java/org/apache/rocketmq/acl/common/AclException.java x: 1 commits (30d) y: 39 lines of code client/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java x: 1 commits (30d) y: 229 lines of code client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java x: 1 commits (30d) y: 122 lines of code client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java x: 1 commits (30d) y: 3092 lines of code common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java x: 2 commits (30d) y: 1424 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java x: 1 commits (30d) y: 1136 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java x: 2 commits (30d) y: 77 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java x: 1 commits (30d) y: 320 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java x: 1 commits (30d) y: 161 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java x: 1 commits (30d) y: 820 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java x: 1 commits (30d) y: 1791 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java x: 1 commits (30d) y: 280 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java x: 1 commits (30d) y: 53 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java x: 1 commits (30d) y: 354 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java x: 1 commits (30d) y: 256 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java x: 2 commits (30d) y: 355 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java x: 1 commits (30d) y: 411 lines of code store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java x: 1 commits (30d) y: 2709 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java x: 1 commits (30d) y: 145 lines of code client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java x: 1 commits (30d) y: 1183 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsHelper.java x: 1 commits (30d) y: 178 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java x: 1 commits (30d) y: 495 lines of code
3092.0
lines of code
  min: 3.0
  average: 463.34
  25th percentile: 98.0
  median: 207.0
  75th percentile: 450.0
  max: 3092.0
0 5.0
commits (30d)
min: 1.0 | average: 1.46 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 5.0

File Size vs. Contributors (30 days): 65 points

common/src/main/java/org/apache/rocketmq/common/MQVersion.java x: 1 contributors (30d) y: 633 lines of code broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java x: 2 contributors (30d) y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java x: 2 contributors (30d) y: 484 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java x: 2 contributors (30d) y: 146 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java x: 2 contributors (30d) y: 599 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java x: 2 contributors (30d) y: 416 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java x: 4 contributors (30d) y: 2976 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java x: 2 contributors (30d) y: 307 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java x: 2 contributors (30d) y: 769 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java x: 2 contributors (30d) y: 943 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java x: 2 contributors (30d) y: 624 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java x: 2 contributors (30d) y: 204 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java x: 2 contributors (30d) y: 207 lines of code store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java x: 2 contributors (30d) y: 148 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java x: 2 contributors (30d) y: 132 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java x: 1 contributors (30d) y: 227 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java x: 2 contributors (30d) y: 367 lines of code client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java x: 2 contributors (30d) y: 351 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/AuthMigrator.java x: 1 contributors (30d) y: 191 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AccessResource.java x: 1 contributors (30d) y: 3 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AclConfig.java x: 1 contributors (30d) y: 25 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessConfig.java x: 1 contributors (30d) y: 86 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessData.java x: 1 contributors (30d) y: 68 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessResource.java x: 1 contributors (30d) y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java x: 3 contributors (30d) y: 2119 lines of code client/src/main/java/org/apache/rocketmq/acl/common/AclException.java x: 1 contributors (30d) y: 39 lines of code client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java x: 1 contributors (30d) y: 122 lines of code client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java x: 1 contributors (30d) y: 3092 lines of code common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java x: 2 contributors (30d) y: 1424 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java x: 1 contributors (30d) y: 1136 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java x: 2 contributors (30d) y: 77 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java x: 1 contributors (30d) y: 320 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java x: 1 contributors (30d) y: 161 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java x: 1 contributors (30d) y: 820 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java x: 1 contributors (30d) y: 1791 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java x: 1 contributors (30d) y: 280 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java x: 1 contributors (30d) y: 53 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java x: 1 contributors (30d) y: 354 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java x: 1 contributors (30d) y: 256 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java x: 2 contributors (30d) y: 355 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java x: 1 contributors (30d) y: 411 lines of code store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java x: 1 contributors (30d) y: 2709 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java x: 1 contributors (30d) y: 145 lines of code client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java x: 1 contributors (30d) y: 1183 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsHelper.java x: 1 contributors (30d) y: 178 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java x: 1 contributors (30d) y: 495 lines of code
3092.0
lines of code
  min: 3.0
  average: 463.34
  25th percentile: 98.0
  median: 207.0
  75th percentile: 450.0
  max: 3092.0
0 4.0
contributors (30d)
min: 1.0 | average: 1.38 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 4.0

File Size vs. Commits (90 days): 112 points

common/src/main/java/org/apache/rocketmq/common/MQVersion.java x: 2 commits (90d) y: 633 lines of code broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java x: 2 commits (90d) y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java x: 2 commits (90d) y: 484 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java x: 2 commits (90d) y: 146 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java x: 4 commits (90d) y: 599 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java x: 2 commits (90d) y: 416 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java x: 7 commits (90d) y: 2976 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java x: 3 commits (90d) y: 307 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java x: 2 commits (90d) y: 769 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java x: 7 commits (90d) y: 943 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java x: 2 commits (90d) y: 204 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java x: 2 commits (90d) y: 207 lines of code store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java x: 2 commits (90d) y: 148 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java x: 2 commits (90d) y: 132 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java x: 3 commits (90d) y: 208 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java x: 2 commits (90d) y: 227 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java x: 3 commits (90d) y: 367 lines of code client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java x: 2 commits (90d) y: 351 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/AuthMigrator.java x: 1 commits (90d) y: 191 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AccessResource.java x: 1 commits (90d) y: 3 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AclConfig.java x: 1 commits (90d) y: 25 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessConfig.java x: 1 commits (90d) y: 86 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessData.java x: 1 commits (90d) y: 68 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessResource.java x: 1 commits (90d) y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java x: 7 commits (90d) y: 2119 lines of code client/src/main/java/org/apache/rocketmq/acl/common/AclException.java x: 1 commits (90d) y: 39 lines of code client/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java x: 1 commits (90d) y: 229 lines of code client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java x: 1 commits (90d) y: 122 lines of code client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java x: 2 commits (90d) y: 3092 lines of code common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java x: 4 commits (90d) y: 1424 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java x: 1 commits (90d) y: 1136 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java x: 2 commits (90d) y: 77 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java x: 1 commits (90d) y: 320 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java x: 1 commits (90d) y: 161 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java x: 1 commits (90d) y: 820 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java x: 3 commits (90d) y: 1791 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java x: 1 commits (90d) y: 280 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java x: 1 commits (90d) y: 53 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java x: 3 commits (90d) y: 354 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java x: 1 commits (90d) y: 256 lines of code broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java x: 2 commits (90d) y: 355 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java x: 1 commits (90d) y: 411 lines of code store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java x: 6 commits (90d) y: 2709 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java x: 1 commits (90d) y: 145 lines of code client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java x: 2 commits (90d) y: 1183 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsHelper.java x: 1 commits (90d) y: 178 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java x: 1 commits (90d) y: 495 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/TopicStatsTable.java x: 1 commits (90d) y: 21 lines of code store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java x: 2 commits (90d) y: 698 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java x: 1 commits (90d) y: 438 lines of code broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java x: 1 commits (90d) y: 195 lines of code broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java x: 2 commits (90d) y: 321 lines of code common/src/main/java/org/apache/rocketmq/common/MixAll.java x: 2 commits (90d) y: 473 lines of code common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java x: 1 commits (90d) y: 101 lines of code store/src/main/java/org/apache/rocketmq/store/CommitLog.java x: 1 commits (90d) y: 1970 lines of code store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java x: 1 commits (90d) y: 910 lines of code store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueStore.java x: 1 commits (90d) y: 444 lines of code broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java x: 1 commits (90d) y: 697 lines of code client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java x: 1 commits (90d) y: 1578 lines of code client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java x: 1 commits (90d) y: 741 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java x: 1 commits (90d) y: 1673 lines of code client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java x: 2 commits (90d) y: 615 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreFetcherImpl.java x: 1 commits (90d) y: 378 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java x: 1 commits (90d) y: 248 lines of code broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java x: 1 commits (90d) y: 219 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java x: 1 commits (90d) y: 624 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java x: 2 commits (90d) y: 1064 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java x: 1 commits (90d) y: 552 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java x: 1 commits (90d) y: 658 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java x: 1 commits (90d) y: 75 lines of code
3092.0
lines of code
  min: 3.0
  average: 440.75
  25th percentile: 111.25
  median: 222.0
  75th percentile: 492.25
  max: 3092.0
0 7.0
commits (90d)
min: 1.0 | average: 1.58 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 7.0

File Size vs. Contributors (90 days): 112 points

common/src/main/java/org/apache/rocketmq/common/MQVersion.java x: 1 contributors (90d) y: 633 lines of code broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java x: 2 contributors (90d) y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java x: 2 contributors (90d) y: 484 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java x: 2 contributors (90d) y: 146 lines of code broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java x: 2 contributors (90d) y: 599 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java x: 2 contributors (90d) y: 416 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java x: 6 contributors (90d) y: 2976 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java x: 3 contributors (90d) y: 307 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java x: 2 contributors (90d) y: 769 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java x: 4 contributors (90d) y: 943 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java x: 2 contributors (90d) y: 624 lines of code broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java x: 2 contributors (90d) y: 204 lines of code broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java x: 2 contributors (90d) y: 207 lines of code store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java x: 2 contributors (90d) y: 148 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java x: 2 contributors (90d) y: 132 lines of code broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java x: 3 contributors (90d) y: 208 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java x: 1 contributors (90d) y: 227 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java x: 3 contributors (90d) y: 367 lines of code client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java x: 2 contributors (90d) y: 351 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/AuthMigrator.java x: 1 contributors (90d) y: 191 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AccessResource.java x: 1 contributors (90d) y: 3 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AclConfig.java x: 1 contributors (90d) y: 25 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessConfig.java x: 1 contributors (90d) y: 86 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessData.java x: 1 contributors (90d) y: 68 lines of code auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessResource.java x: 1 contributors (90d) y: 116 lines of code broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java x: 6 contributors (90d) y: 2119 lines of code client/src/main/java/org/apache/rocketmq/acl/common/AclException.java x: 1 contributors (90d) y: 39 lines of code client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java x: 1 contributors (90d) y: 122 lines of code client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java x: 2 contributors (90d) y: 3092 lines of code common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java x: 2 contributors (90d) y: 1424 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java x: 1 contributors (90d) y: 1136 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java x: 2 contributors (90d) y: 77 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java x: 1 contributors (90d) y: 320 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java x: 1 contributors (90d) y: 161 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java x: 1 contributors (90d) y: 820 lines of code tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java x: 3 contributors (90d) y: 1791 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java x: 1 contributors (90d) y: 280 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java x: 1 contributors (90d) y: 53 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java x: 2 contributors (90d) y: 354 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java x: 1 contributors (90d) y: 256 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java x: 1 contributors (90d) y: 411 lines of code store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java x: 4 contributors (90d) y: 2709 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java x: 1 contributors (90d) y: 145 lines of code client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java x: 2 contributors (90d) y: 1183 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsHelper.java x: 1 contributors (90d) y: 178 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java x: 1 contributors (90d) y: 495 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/TopicStatsTable.java x: 1 contributors (90d) y: 21 lines of code store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java x: 1 contributors (90d) y: 698 lines of code proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java x: 1 contributors (90d) y: 438 lines of code broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java x: 1 contributors (90d) y: 195 lines of code broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java x: 1 contributors (90d) y: 769 lines of code broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java x: 2 contributors (90d) y: 321 lines of code common/src/main/java/org/apache/rocketmq/common/MixAll.java x: 2 contributors (90d) y: 473 lines of code common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java x: 1 contributors (90d) y: 101 lines of code store/src/main/java/org/apache/rocketmq/store/CommitLog.java x: 1 contributors (90d) y: 1970 lines of code store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java x: 1 contributors (90d) y: 910 lines of code store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueStore.java x: 1 contributors (90d) y: 444 lines of code client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java x: 1 contributors (90d) y: 1578 lines of code client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java x: 1 contributors (90d) y: 741 lines of code store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java x: 1 contributors (90d) y: 1673 lines of code client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java x: 2 contributors (90d) y: 615 lines of code tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreFetcherImpl.java x: 1 contributors (90d) y: 378 lines of code tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java x: 1 contributors (90d) y: 248 lines of code broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java x: 1 contributors (90d) y: 219 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java x: 2 contributors (90d) y: 1064 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java x: 1 contributors (90d) y: 552 lines of code remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java x: 1 contributors (90d) y: 658 lines of code namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java x: 1 contributors (90d) y: 75 lines of code
3092.0
lines of code
  min: 3.0
  average: 440.75
  25th percentile: 111.25
  median: 222.0
  75th percentile: 492.25
  max: 3092.0
0 6.0
contributors (90d)
min: 1.0 | average: 1.43 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 6.0