6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionItem.java (79:85, 14%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java (216:222, 3%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/canal/CanalRecordPartition.java (47:53, 27%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java (216:222, 3%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/jdbc/JdbcRecordPartition.java (43:49, 30%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java (53:59, 20%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/rocketmq/RocketMQRecordPartition.java (52:58, 26%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java (216:222, 3%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/S3/S3RecordPartition.java (47:53, 27%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java (216:222, 3%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/kafka/KafkaRecordPartition.java (45:51, 28%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java (216:222, 3%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/canal/CanalRecordPartition.java (47:53, 27%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java (53:59, 20%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/pulsar/PulsarRecordPartition.java (46:52, 27%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java (216:222, 3%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/file/FileRecordPartition.java (43:49, 30%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java (53:59, 20%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/S3/S3RecordPartition.java (47:53, 27%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ConsumerGroupConf.java (49:55, 18%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/UserAgent.java (74:81, 6%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java (53:59, 20%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/UserAgent.java (74:81, 6%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java (216:222, 3%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/pulsar/PulsarRecordPartition.java (46:52, 27%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ConsumerGroupConf.java (49:55, 18%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/S3/S3RecordPartition.java (47:53, 27%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java (53:59, 20%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/pulsar/PulsarRecordPartition.java (46:52, 27%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java (53:59, 20%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/jdbc/JdbcRecordPartition.java (43:49, 30%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ConsumerGroupConf.java (49:55, 18%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/UserAgent.java (74:81, 6%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ConsumerGroupConf.java (49:55, 18%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/rocketmq/RocketMQRecordPartition.java (52:58, 26%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java (53:59, 20%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/kafka/KafkaRecordPartition.java (45:51, 28%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java (53:59, 20%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/canal/CanalRecordPartition.java (47:53, 27%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ConsumerGroupConf.java (49:55, 18%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/file/FileRecordPartition.java (43:49, 30%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ConsumerGroupConf.java (49:55, 18%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/rocketmq/RocketMQRecordPartition.java (52:58, 26%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ConsumerGroupConf.java (49:55, 18%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionItem.java (79:85, 14%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java (53:59, 20%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/file/FileRecordPartition.java (43:49, 30%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java (216:222, 3%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/jdbc/JdbcRecordPartition.java (43:49, 30%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java (216:222, 3%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionItem.java (79:85, 14%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ConsumerGroupConf.java (49:55, 18%) 6 duplicated lines in: - eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/kafka/KafkaRecordPartition.java (45:51, 28%) - eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ConsumerGroupConf.java (49:55, 18%)