13 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/stats/StatsSnapshot.java (25:48, 61%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BrokerStatsItem.java (23:46, 81%) 12 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/TopicConfig.java (145:166, 7%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/QueueData.java (43:64, 16%) 10 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java (66:77, 12%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/GroupForbidden.java (61:72, 24%) 10 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java (73:84, 14%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/GroupForbidden.java (61:72, 24%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java (67:77, 11%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/QueueData.java (84:94, 12%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java (74:84, 13%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java (195:205, 6%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java (74:84, 13%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/TopicRouteData.java (181:191, 6%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java (39:49, 23%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/SubscriptionData.java (125:135, 8%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java (39:49, 23%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java (195:205, 6%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java (74:84, 13%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/QueueData.java (84:94, 12%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java (67:77, 11%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/SubscriptionData.java (125:135, 8%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java (39:49, 23%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/QueueData.java (84:94, 12%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java (39:49, 23%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/TopicRouteData.java (181:191, 6%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java (67:77, 11%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/TopicRouteData.java (181:191, 6%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java (67:77, 11%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java (195:205, 6%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java (74:84, 13%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/SubscriptionData.java (125:135, 8%) 9 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java (39:49, 23%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/GroupForbidden.java (62:72, 21%) 8 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java (120:133, 10%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumeByWho.java (53:66, 30%) 7 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/MixAll.java (354:360, 2%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java (437:443, 1%) 6 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/TopicConfig.java (218:224, 3%) - remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcRequestHeader.java (75:81, 13%) 6 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/TopicConfig.java (218:224, 3%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ElectMasterResponseBody.java (45:51, 15%) 6 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/Message.java (206:215, 4%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/EndTransactionRequestHeader.java (128:137, 8%) 6 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/TopicConfig.java (218:224, 3%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SimpleSubscriptionData.java (68:74, 13%) 6 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/TopicConfig.java (218:224, 3%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BrokerMemberGroup.java (73:79, 13%) 6 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java (92:97, 8%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/SubscriptionData.java (155:160, 5%) 6 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java (34:39, 23%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ClusterInfo.java (67:72, 18%) 6 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java (100:105, 9%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ClusterInfo.java (67:72, 18%) 6 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/TopicConfig.java (218:224, 3%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/EpochEntry.java (78:85, 13%) 6 duplicated lines in: - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java (85:90, 7%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/SubscriptionData.java (155:160, 5%)