6 duplicated lines in:
  - samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java (68:74, 20%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java (108:114, 10%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java (184:190, 4%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java (73:79, 20%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java (56:62, 20%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java (147:153, 7%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java (42:48, 30%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java (46:52, 25%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java (156:162, 5%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java (45:51, 25%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java (70:76, 16%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java (59:65, 17%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)

6 duplicated lines in:
  - samza-core/src/main/java/org/apache/samza/context/ContextImpl.java (90:96, 10%)
  - samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java (78:84, 13%)