12 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java (52:73, 9%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PeekMessageRequestHeader.java (45:66, 40%) 10 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java (56:73, 8%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ChangeInvisibleTimeRequestHeader.java (86:103, 19%) 10 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java (56:73, 8%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/AckMessageRequestHeader.java (70:87, 22%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java (195:205, 6%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/GroupForbidden.java (62:72, 21%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java (52:68, 7%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/StatisticsMessagesRequestHeader.java (39:55, 27%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/QueueData.java (84:94, 12%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/TopicRouteData.java (181:191, 6%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/SubscriptionData.java (125:135, 8%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java (52:68, 7%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PollingInfoRequestHeader.java (44:60, 34%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java (158:171, 4%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageResponseHeader.java (96:109, 12%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java (52:65, 6%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumeStatsRequestHeader.java (76:89, 20%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java (232:245, 5%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/ConsumerData.java (43:56, 22%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java (126:139, 4%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/RecallMessageRequestHeader.java (46:59, 26%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java (126:139, 4%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ReplyMessageRequestHeader.java (67:80, 8%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java (60:73, 6%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryConsumeQueueRequestHeader.java (39:52, 25%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java (134:147, 4%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ResumeCheckHalfMessageRequestHeader.java (42:55, 42%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java (232:245, 5%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumerConnection.java (64:77, 24%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java (52:65, 6%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BatchAck.java (45:58, 11%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java (189:198, 5%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PopMessageRequestHeader.java (167:176, 6%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java (159:165, 6%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SimpleSubscriptionData.java (68:74, 13%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerAttr.java (36:41, 28%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ClusterInfo.java (67:72, 18%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java (189:198, 5%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/NotificationRequestHeader.java (103:112, 10%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java (162:171, 3%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PullMessageRequestHeader.java (226:235, 3%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/metrics/PopMetricsManager.java (74:79, 4%) - remoting/src/main/java/org/apache/rocketmq/remoting/metrics/RemotingMetricsManager.java (71:76, 14%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java (159:165, 6%) - remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcRequestHeader.java (75:81, 13%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java (159:165, 6%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/EpochEntry.java (78:85, 13%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/metrics/ProducerAttr.java (31:36, 35%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ClusterInfo.java (67:72, 18%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java (159:165, 6%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ElectMasterResponseBody.java (45:51, 15%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java (159:165, 6%) - remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BrokerMemberGroup.java (73:79, 13%)