Path	Lines of Code
broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java	2119
broker/src/main/java/org/apache/rocketmq/broker/BrokerPathConfigHelper.java	48
broker/src/main/java/org/apache/rocketmq/broker/BrokerPreOnlineService.java	233
broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java	252
broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java	116
broker/src/main/java/org/apache/rocketmq/broker/ShutdownHook.java	4
broker/src/main/java/org/apache/rocketmq/broker/auth/converter/AclConverter.java	96
broker/src/main/java/org/apache/rocketmq/broker/auth/converter/UserConverter.java	33
broker/src/main/java/org/apache/rocketmq/broker/auth/pipeline/AuthenticationPipeline.java	41
broker/src/main/java/org/apache/rocketmq/broker/auth/pipeline/AuthorizationPipeline.java	43
broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelAttributeHelper.java	51
broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java	70
broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java	65
broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java	8
broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java	193
broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java	5
broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java	355
broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java	133
broker/src/main/java/org/apache/rocketmq/broker/client/ProducerChangeListener.java	4
broker/src/main/java/org/apache/rocketmq/broker/client/ProducerGroupEvent.java	5
broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java	282
broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java	256
broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java	212
broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdCtrStrategy.java	7
broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java	195
broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataPullRequestHoldService.java	71
broker/src/main/java/org/apache/rocketmq/broker/coldctr/PIDAdaptiveColdCtrStrategy.java	56
broker/src/main/java/org/apache/rocketmq/broker/coldctr/SimpleColdCtrStrategy.java	29
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java	132
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBLmqSubscriptionGroupManager.java	33
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBLmqTopicConfigManager.java	34
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBOffsetSerializeWrapper.java	13
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java	208
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManager.java	128
broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConfigHelper.java	93
broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConfigStorage.java	191
broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConsumerOffsetManagerV2.java	320
broker/src/main/java/org/apache/rocketmq/broker/config/v2/RecordPrefix.java	13
broker/src/main/java/org/apache/rocketmq/broker/config/v2/SerializationType.java	22
broker/src/main/java/org/apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java	142
broker/src/main/java/org/apache/rocketmq/broker/config/v2/TableId.java	15
broker/src/main/java/org/apache/rocketmq/broker/config/v2/TablePrefix.java	12
broker/src/main/java/org/apache/rocketmq/broker/config/v2/TopicConfigManagerV2.java	145
broker/src/main/java/org/apache/rocketmq/broker/config/v2/package-info.java	1
broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java	681
broker/src/main/java/org/apache/rocketmq/broker/dledger/DLedgerRoleChangeHandler.java	145
broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java	335
broker/src/main/java/org/apache/rocketmq/broker/filter/CommitLogDispatcherCalcBitMap.java	69
broker/src/main/java/org/apache/rocketmq/broker/filter/ConsumerFilterData.java	97
broker/src/main/java/org/apache/rocketmq/broker/filter/ConsumerFilterManager.java	354
broker/src/main/java/org/apache/rocketmq/broker/filter/ExpressionForRetryMessageFilter.java	59
broker/src/main/java/org/apache/rocketmq/broker/filter/ExpressionMessageFilter.java	113
broker/src/main/java/org/apache/rocketmq/broker/filter/MessageEvaluationContext.java	29
broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java	128
broker/src/main/java/org/apache/rocketmq/broker/loadbalance/MessageRequestModeManager.java	63
broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java	43
broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java	26
broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotificationRequest.java	31
broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotifyMessageArrivingListener.java	25
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PollingHeader.java	39
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PollingResult.java	7
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopCommandCallback.java	24
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopLongPollingService.java	356
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopRequest.java	73
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java	46
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java	165
broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsConstant.java	43
broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsManager.java	605
broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerAttr.java	29
broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerLagCalculator.java	444
broker/src/main/java/org/apache/rocketmq/broker/metrics/InvocationStatus.java	12
broker/src/main/java/org/apache/rocketmq/broker/metrics/PopMetricsConstant.java	14
broker/src/main/java/org/apache/rocketmq/broker/metrics/PopMetricsManager.java	187
broker/src/main/java/org/apache/rocketmq/broker/metrics/PopReviveMessageType.java	5
broker/src/main/java/org/apache/rocketmq/broker/metrics/ProducerAttr.java	24
broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java	174
broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageHook.java	6
broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java	230
broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageHook.java	6
broker/src/main/java/org/apache/rocketmq/broker/offset/BroadcastOffsetManager.java	159
broker/src/main/java/org/apache/rocketmq/broker/offset/BroadcastOffsetStore.java	32
broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java	357
broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java	146
broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java	484
broker/src/main/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java	100
broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java	1271
broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java	79
broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java	68
broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java	79
broker/src/main/java/org/apache/rocketmq/broker/plugin/BrokerAttachedPlugin.java	12
broker/src/main/java/org/apache/rocketmq/broker/plugin/PullMessageResultHandler.java	22
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerCache.java	242
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerContext.java	125
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerKVStore.java	10
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerLockService.java	69
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java	146
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java	129
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java	599
broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java	495
broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java	416
broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java	2976
broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java	307
broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java	237
broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java	299
broker/src/main/java/org/apache/rocketmq/broker/processor/DefaultPullMessageResultHandler.java	246
broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java	297
broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java	189
broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java	262
broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java	90
broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java	769
broker/src/main/java/org/apache/rocketmq/broker/processor/PopInflightMessageCounter.java	123
broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java	943
broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java	624
broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java	769
broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java	266
broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java	144
broker/src/main/java/org/apache/rocketmq/broker/processor/RecallMessageProcessor.java	157
broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java	303
broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageCallback.java	6
broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java	593
broker/src/main/java/org/apache/rocketmq/broker/schedule/DelayOffsetSerializeWrapper.java	22
broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java	697
broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java	219
broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java	33
broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java	321
broker/src/main/java/org/apache/rocketmq/broker/topic/LmqTopicConfigManager.java	34
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java	624
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingCleanService.java	297
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java	204
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicRouteInfoManager.java	203
broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java	81
broker/src/main/java/org/apache/rocketmq/broker/transaction/OperationResult.java	25
broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java	207
broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetricsFlushService.java	34
broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageCheckService.java	38
broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageService.java	18
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/DefaultTransactionalMessageCheckListener.java	58
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/GetResult.java	19
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/MessageQueueOpContext.java	24
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java	310
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java	616
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageUtil.java	63
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalOpBatchService.java	40
broker/src/main/java/org/apache/rocketmq/broker/util/HookUtils.java	194
broker/src/main/java/org/apache/rocketmq/broker/util/PositiveAtomicCounter.java	16
broker/src/main/resources/rmq.broker.logback.xml	664
broker/src/main/resources/transaction.sql	4