15 duplicated lines in:
  - gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java (51:73, 16%)
  - gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/Kafka08DataWriter.java (54:76, 23%)

15 duplicated lines in:
  - gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java (51:73, 16%)
  - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/writer/Kafka1DataWriter.java (51:72, 14%)

15 duplicated lines in:
  - gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java (51:73, 16%)
  - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java (61:82, 15%)

10 duplicated lines in:
  - gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java (90:104, 15%)
  - gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriter.java (144:158, 10%)

8 duplicated lines in:
  - gobblin-core-base/src/main/java/org/apache/gobblin/writer/FutureWrappedWriteCallback.java (44:55, 13%)
  - gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseWriter.java (191:202, 4%)

8 duplicated lines in:
  - gobblin-core-base/src/main/java/org/apache/gobblin/writer/FutureWrappedWriteCallback.java (44:55, 13%)
  - gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer/FutureCallbackHolder.java (57:68, 7%)

6 duplicated lines in:
  - gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java (64:70, 18%)
  - gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadata.java (337:343, 3%)