duplicated block id: 1
size: 11 cleaned lines of code
in 2 files:
 - kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java (130:144)
 - kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java (166:180)

duplicated block id: 2
size: 10 cleaned lines of code
in 2 files:
 - flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java (79:91)
 - flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSource.java (117:129)

duplicated block id: 3
size: 9 cleaned lines of code
in 2 files:
 - sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSqlSink.java (15:26)
 - sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSqlSource.java (15:26)

duplicated block id: 4
size: 9 cleaned lines of code
in 2 files:
 - kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkConnector.java (12:25)
 - kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PubSubLiteSourceConnector.java (13:26)

duplicated block id: 5
size: 9 cleaned lines of code
in 2 files:
 - sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/CloudPubsubProvider.java (63:75)
 - sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/KafkaProvider.java (42:59)

duplicated block id: 6
size: 8 cleaned lines of code
in 2 files:
 - kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java (227:234)
 - kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java (265:272)

duplicated block id: 7
size: 7 cleaned lines of code
in 2 files:
 - kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java (150:157)
 - kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java (137:144)

duplicated block id: 8
size: 7 cleaned lines of code
in 2 files:
 - kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java (51:57)
 - kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java (73:79)

duplicated block id: 9
size: 6 cleaned lines of code
in 2 files:
 - kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubGRPCSubscriber.java (93:98)
 - kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java (305:310)

duplicated block id: 10
size: 6 cleaned lines of code
in 2 files:
 - kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java (112:120)
 - kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java (125:133)

duplicated block id: 11
size: 6 cleaned lines of code
in 2 files:
 - kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java (88:98)
 - kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java (98:108)

duplicated block id: 12
size: 6 cleaned lines of code
in 2 files:
 - sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/CloudPubsubProvider.java (69:76)
 - sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/CloudPubsubProvider.java (86:93)

duplicated block id: 13
size: 6 cleaned lines of code
in 2 files:
 - kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/ConfigDefs.java (15:20)
 - kafka-connector/src/main/java/com/google/pubsublite/kafka/source/ConfigDefs.java (18:23)

duplicated block id: 14
size: 6 cleaned lines of code
in 2 files:
 - kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java (247:252)
 - kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java (278:283)