duplicated block id: 1 size: 17 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala (100:116) - core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala (565:581) duplicated block id: 2 size: 11 cleaned lines of code in 2 files: - testkit/src/main/scala/org/apache/pekko/kafka/testkit/KafkaTestkitTestcontainersSettings.scala (261:271) - testkit/src/main/scala/org/apache/pekko/kafka/testkit/KafkaTestkitTestcontainersSettings.scala (328:338) duplicated block id: 3 size: 11 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/internal/SingleSourceLogic.scala (83:99) - core/src/main/scala/org/apache/pekko/kafka/internal/SubSourceLogic.scala (287:304) duplicated block id: 4 size: 10 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala (55:65) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionFixtures.scala (51:61) duplicated block id: 5 size: 10 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala (118:129) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionBenchmarks.scala (41:52) duplicated block id: 6 size: 9 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (286:295) - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (352:361) duplicated block id: 7 size: 9 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala (68:76) - core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala (86:94) duplicated block id: 8 size: 9 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (315:324) - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (375:384) duplicated block id: 9 size: 8 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/Timed.scala (86:93) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/Timed.scala (110:117) duplicated block id: 10 size: 8 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (335:347) - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (357:369) duplicated block id: 11 size: 8 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (267:281) - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (291:309) duplicated block id: 12 size: 8 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala (68:77) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala (88:97) duplicated block id: 13 size: 8 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala (97:106) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala (149:158) duplicated block id: 14 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (283:289) - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (312:318) duplicated block id: 15 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/internal/BaseSingleSourceLogic.scala (101:107) - core/src/main/scala/org/apache/pekko/kafka/internal/SubSourceLogic.scala (468:474) duplicated block id: 16 size: 7 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerFixtures.scala (60:67) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaProducerFixtures.scala (56:63) duplicated block id: 17 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/Metadata.scala (95:106) - core/src/main/scala/org/apache/pekko/kafka/Metadata.scala (125:136) duplicated block id: 18 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (349:355) - core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (372:378) duplicated block id: 19 size: 7 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerBenchmarks.scala (114:120) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerBenchmarks.scala (142:148) duplicated block id: 20 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/Subscriptions.scala (99:107) - core/src/main/scala/org/apache/pekko/kafka/Subscriptions.scala (120:128) duplicated block id: 21 size: 7 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala (87:94) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala (140:147) duplicated block id: 22 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/javadsl/Producer.scala (300:305) - core/src/main/scala/org/apache/pekko/kafka/scaladsl/Producer.scala (294:299) duplicated block id: 23 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala (107:112) - core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala (131:136) duplicated block id: 24 size: 6 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala (80:85) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala (103:108) duplicated block id: 25 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/internal/BaseSingleSourceLogic.scala (78:83) - core/src/main/scala/org/apache/pekko/kafka/internal/SubSourceLogic.scala (432:437) duplicated block id: 26 size: 6 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerFixtures.scala (35:40) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionFixtures.scala (51:56) duplicated block id: 27 size: 6 cleaned lines of code in 2 files: - testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaJunit4Test.java (54:63) - testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaTest.java (54:63) duplicated block id: 28 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalSources.scala (133:138) - core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalSources.scala (420:425) duplicated block id: 29 size: 6 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala (36:41) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala (180:185) duplicated block id: 30 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalSources.scala (125:131) - core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalSources.scala (412:418) duplicated block id: 31 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/internal/CommittableSources.scala (50:60) - core/src/main/scala/org/apache/pekko/kafka/internal/CommittableSources.scala (71:81) duplicated block id: 32 size: 6 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala (55:60) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala (180:185) duplicated block id: 33 size: 6 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerBenchmarks.scala (51:57) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerBenchmarks.scala (66:72) duplicated block id: 34 size: 6 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala (36:41) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala (55:60) duplicated block id: 35 size: 6 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerBenchmarks.scala (179:185) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionBenchmarks.scala (66:72) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala (55:60) - benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerFixtures.scala (35:40) duplicated block id: 37 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/pekko/kafka/internal/LoggingWithId.scala (34:40) - core/src/main/scala/org/apache/pekko/kafka/internal/LoggingWithId.scala (48:54)