duplicated block id: 1 size: 41 cleaned lines of code in 2 files: - broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java (181:226) - store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java (235:280) duplicated block id: 2 size: 23 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java (68:96) - tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java (65:93) duplicated block id: 3 size: 18 cleaned lines of code in 2 files: - auth/src/main/java/org/apache/rocketmq/auth/authorization/factory/AuthorizationFactory.java (136:155) - auth/src/main/java/org/apache/rocketmq/auth/authentication/factory/AuthenticationFactory.java (133:152) duplicated block id: 4 size: 16 cleaned lines of code in 2 files: - client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopOrderlyService.java (275:292) - client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java (360:377) duplicated block id: 5 size: 14 cleaned lines of code in 2 files: - controller/src/main/java/org/apache/rocketmq/controller/ControllerStartup.java (128:148) - namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java (160:180) duplicated block id: 6 size: 13 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java (47:65) - tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java (68:86) duplicated block id: 7 size: 13 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateColdDataFlowCtrGroupConfigSubCommand.java (46:64) - tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicPermSubCommand.java (51:69) duplicated block id: 8 size: 13 cleaned lines of code in 2 files: - client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java (78:93) - client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java (59:74) duplicated block id: 9 size: 11 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/auth/ListUserSubCommand.java (50:67) - tools/src/main/java/org/apache/rocketmq/tools/command/auth/GetUserSubCommand.java (49:66) duplicated block id: 10 size: 11 cleaned lines of code in 2 files: - auth/src/main/java/org/apache/rocketmq/auth/authorization/context/AuthorizationContext.java (32:44) - auth/src/main/java/org/apache/rocketmq/auth/authentication/context/AuthenticationContext.java (48:60) duplicated block id: 11 size: 10 cleaned lines of code in 3 files: - tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java (48:62) - tools/src/main/java/org/apache/rocketmq/tools/command/broker/DeleteExpiredCommitLogSubCommand.java (44:58) - tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerEpochSubCommand.java (45:59) duplicated block id: 12 size: 10 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/broker/SendMsgStatusCommand.java (56:70) - tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java (47:60) duplicated block id: 13 size: 10 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/broker/CommitLogSetReadAheadSubCommand.java (51:65) - tools/src/main/java/org/apache/rocketmq/tools/command/broker/RemoveColdDataFlowCtrGroupConfigSubCommand.java (43:57) duplicated block id: 14 size: 10 cleaned lines of code in 3 files: - tools/src/main/java/org/apache/rocketmq/tools/command/offset/GetConsumerStatusCommand.java (43:57) - tools/src/main/java/org/apache/rocketmq/tools/command/auth/CopyAclsSubCommand.java (46:61) - tools/src/main/java/org/apache/rocketmq/tools/command/auth/CopyUsersSubCommand.java (46:61) duplicated block id: 15 size: 10 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/controller/UpdateControllerConfigSubCommand.java (44:58) - tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java (39:52) duplicated block id: 16 size: 10 cleaned lines of code in 2 files: - remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsHelper.java (212:225) - proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolTlsHelper.java (100:113) duplicated block id: 17 size: 10 cleaned lines of code in 3 files: - example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingProducer.java (65:77) - example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingPushConsumer.java (58:70) - example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingTransactionProducer.java (84:96) duplicated block id: 18 size: 9 cleaned lines of code in 2 files: - broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java (2261:2271) - store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java (2162:2172) duplicated block id: 19 size: 9 cleaned lines of code in 2 files: - client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java (217:228) - client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java (183:193) duplicated block id: 20 size: 8 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportConfigsCommand.java (50:60) - tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetricsCommand.java (63:73) duplicated block id: 21 size: 7 cleaned lines of code in 7 files: - tools/src/main/java/org/apache/rocketmq/tools/command/connection/ProducerConnectionSubCommand.java (43:53) - tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java (66:76) - tools/src/main/java/org/apache/rocketmq/tools/command/topic/AllocateMQSubCommand.java (48:58) - tools/src/main/java/org/apache/rocketmq/tools/command/container/RemoveBrokerSubCommand.java (40:50) - tools/src/main/java/org/apache/rocketmq/tools/command/container/AddBrokerSubCommand.java (40:50) - tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java (39:48) - tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateNamesrvConfigCommand.java (43:53) duplicated block id: 22 size: 7 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java (46:56) - tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java (49:58) duplicated block id: 23 size: 7 cleaned lines of code in 6 files: - tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanUnusedTopicCommand.java (41:51) - tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanExpiredCQSubCommand.java (41:51) - tools/src/main/java/org/apache/rocketmq/tools/command/broker/ResetMasterFlushOffsetSubCommand.java (40:50) - tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java (52:62) - tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetColdDataFlowCtrInfoSubCommand.java (54:64) - example/src/main/java/org/apache/rocketmq/example/benchmark/timer/TimerConsumer.java (145:155) duplicated block id: 24 size: 7 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java (54:64) - tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java (49:58) duplicated block id: 25 size: 7 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageByQueueCommand.java (43:53) - tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java (38:47) duplicated block id: 26 size: 7 cleaned lines of code in 2 files: - common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java (87:95) - common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java (190:198) duplicated block id: 27 size: 7 cleaned lines of code in 2 files: - common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java (97:105) - common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java (200:208) duplicated block id: 28 size: 7 cleaned lines of code in 2 files: - broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java (262:270) - container/src/main/java/org/apache/rocketmq/container/BrokerContainerStartup.java (369:377) duplicated block id: 29 size: 7 cleaned lines of code in 2 files: - client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java (433:442) - client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java (1173:1182) duplicated block id: 30 size: 7 cleaned lines of code in 2 files: - client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java (155:163) - client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java (79:87) duplicated block id: 31 size: 7 cleaned lines of code in 2 files: - controller/src/main/java/org/apache/rocketmq/controller/ControllerStartup.java (154:164) - namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java (229:238) duplicated block id: 32 size: 7 cleaned lines of code in 2 files: - auth/src/main/java/org/apache/rocketmq/auth/authorization/context/AuthorizationContext.java (46:54) - auth/src/main/java/org/apache/rocketmq/auth/authentication/context/AuthenticationContext.java (62:70) duplicated block id: 33 size: 6 cleaned lines of code in 2 files: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java (61:68) - common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java (68:75) duplicated block id: 34 size: 6 cleaned lines of code in 3 files: - broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java (30:37) - broker/src/main/java/org/apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java (121:128) - broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBLmqSubscriptionGroupManager.java (30:37) duplicated block id: 35 size: 6 cleaned lines of code in 3 files: - broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManager.java (158:165) - broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java (164:171) - broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java (201:208) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - broker/src/main/java/org/apache/rocketmq/broker/topic/TopicRouteInfoManager.java (181:188) - client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java (457:464) duplicated block id: 37 size: 6 cleaned lines of code in 4 files: - broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java (3312:3319) - controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java (332:339) - container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java (277:284) - namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java (675:682) duplicated block id: 38 size: 6 cleaned lines of code in 2 files: - store/src/main/java/org/apache/rocketmq/store/metrics/RocksDBStoreMetricsManager.java (146:153) - store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsManager.java (243:250) duplicated block id: 39 size: 6 cleaned lines of code in 3 files: - client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java (106:113) - client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java (676:683) - client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java (483:490) duplicated block id: 40 size: 6 cleaned lines of code in 2 files: - client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java (423:430) - client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java (1163:1170) duplicated block id: 41 size: 6 cleaned lines of code in 2 files: - remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java (341:349) - remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java (876:884) duplicated block id: 42 size: 6 cleaned lines of code in 2 files: - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/UnlockBatchRequestBody.java (65:72) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/LockBatchRequestBody.java (65:72) duplicated block id: 43 size: 6 cleaned lines of code in 2 files: - auth/src/main/java/org/apache/rocketmq/auth/authorization/manager/AuthorizationMetadataManagerImpl.java (54:61) - auth/src/main/java/org/apache/rocketmq/auth/authentication/manager/AuthenticationMetadataManagerImpl.java (48:55)