23 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/pulsarmq/PulsarMQCanalConnector.java (252:293, 10%) - connector/pulsarmq-connector/src/main/java/com/alibaba/otter/canal/connector/pulsarmq/consumer/CanalPulsarMQConsumer.java (182:222, 15%) 20 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/ConsumerBatchMessage.java (7:45, 100%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/ConsumerBatchMessage.java (7:45, 100%) 20 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/ConsumerBatchMessage.java (7:45, 100%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/ConsumerBatchMessage.java (7:45, 100%) 14 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (257:274, 7%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (166:183, 9%) 14 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (257:274, 7%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (145:162, 10%) 13 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (194:208, 6%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (166:180, 8%) 13 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (194:208, 6%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (145:159, 9%) 13 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (119:137, 7%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (110:128, 9%) 12 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/AliyunCredentialsProvider.java (33:50, 70%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/producer/AliyunCredentialsProvider.java (32:48, 70%) 12 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java (27:44, 38%) - connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/CanalMessageSerializerUtil.java (101:118, 16%) 12 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (29:49, 6%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (43:60, 9%) 10 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java (13:24, 32%) - connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/CanalMessageSerializerUtil.java (87:98, 13%) 9 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (75:83, 4%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (96:106, 6%) 9 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (277:290, 4%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (194:207, 6%) 9 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (276:289, 4%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (215:228, 6%) 9 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (109:122, 4%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (105:118, 6%) 9 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (277:290, 4%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (215:228, 6%) 9 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (276:289, 4%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (194:207, 6%) 8 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java (291:304, 3%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/config/RabbitMQProducerConfig.java (46:59, 19%) 8 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (148:157, 4%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (127:135, 5%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (228:234, 3%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (170:176, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (200:206, 3%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (191:197, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (228:234, 3%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (191:197, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/pulsarmq/PulsarMQCanalConnector.java (59:86, 2%) - connector/pulsarmq-connector/src/main/java/com/alibaba/otter/canal/connector/pulsarmq/consumer/CanalPulsarMQConsumer.java (52:79, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (100:105, 3%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (92:97, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (59:64, 3%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (56:61, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (264:270, 3%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (170:176, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (236:242, 3%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (170:176, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (200:206, 3%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (170:176, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (236:242, 3%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (191:197, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java (264:270, 3%) - connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java (191:197, 4%) 6 duplicated lines in: - client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java (68:73, 3%) - connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java (83:88, 4%)