duplicated block id: 1 size: 70 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextAdapter.java (53:168) - streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextReverseAdapter.java (49:164) duplicated block id: 2 size: 38 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (51:98) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java (46:92) duplicated block id: 3 size: 36 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/utils/LogContext.java (80:137) - clients/src/main/java/org/apache/kafka/common/utils/LogContext.java (446:503) duplicated block id: 4 size: 32 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (294:346) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (487:539) duplicated block id: 5 size: 31 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (101:141) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (114:158) duplicated block id: 6 size: 31 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (162:207) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (394:437) duplicated block id: 7 size: 30 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java (77:121) - clients/src/main/java/org/apache/kafka/common/utils/Crc32.java (114:157) duplicated block id: 8 size: 29 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (78:109) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (79:110) duplicated block id: 9 size: 28 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/RecordsReadable.java (35:80) - clients/src/main/java/org/apache/kafka/common/protocol/ByteBufferAccessor.java (28:73) duplicated block id: 10 size: 28 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (145:186) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (162:205) duplicated block id: 11 size: 27 cleaned lines of code in 2 files: - streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/serialization/Serdes.scala (46:76) - streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala (47:77) duplicated block id: 12 size: 24 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java (130:167) - streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextAdapter.java (192:229) - streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextReverseAdapter.java (205:242) duplicated block id: 13 size: 24 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java (73:110) - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java (80:117) duplicated block id: 14 size: 24 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java (66:92) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java (52:78) duplicated block id: 15 size: 23 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java (40:122) - streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalApiProcessorContext.java (36:118) duplicated block id: 16 size: 23 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java (48:82) - clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java (135:175) duplicated block id: 17 size: 22 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (48:77) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (53:83) duplicated block id: 18 size: 21 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkConnector.java (33:66) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceConnector.java (33:66) duplicated block id: 19 size: 21 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClient.java (124:154) - clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java (154:184) duplicated block id: 20 size: 20 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java (73:100) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java (74:101) duplicated block id: 21 size: 20 cleaned lines of code in 2 files: - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java (117:137) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java (93:113) duplicated block id: 22 size: 19 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java (73:98) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java (72:97) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java (74:99) duplicated block id: 23 size: 19 cleaned lines of code in 2 files: - streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionConversions.scala (50:84) - streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionsCompatConversions.scala (57:91) duplicated block id: 24 size: 19 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java (158:186) - streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueByteStoreAdapter.java (79:107) duplicated block id: 25 size: 17 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (150:166) - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (187:203) duplicated block id: 26 size: 16 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java (71:91) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java (74:94) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java (72:92) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java (73:93) duplicated block id: 27 size: 16 cleaned lines of code in 3 files: - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java (83:98) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java (98:113) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java (122:137) duplicated block id: 28 size: 16 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java (52:77) - streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextAdapter.java (56:81) - streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextReverseAdapter.java (52:77) duplicated block id: 29 size: 16 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java (239:261) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java (248:270) duplicated block id: 30 size: 16 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (153:168) - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (226:241) duplicated block id: 31 size: 16 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializer.java (45:65) - streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java (61:81) duplicated block id: 32 size: 16 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (186:204) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (300:320) duplicated block id: 33 size: 16 cleaned lines of code in 2 files: - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java (62:85) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java (71:94) duplicated block id: 34 size: 16 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java (102:123) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java (83:104) duplicated block id: 35 size: 16 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java (411:428) - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBRangeIterator.java (58:74) duplicated block id: 36 size: 15 cleaned lines of code in 3 files: - streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java (51:70) - streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java (46:65) - streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java (60:79) duplicated block id: 37 size: 15 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (125:139) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (386:400) duplicated block id: 38 size: 15 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java (90:113) - tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java (74:97) duplicated block id: 39 size: 15 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java (422:445) - tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java (387:410) duplicated block id: 40 size: 15 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java (379:394) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (487:502) duplicated block id: 41 size: 15 cleaned lines of code in 2 files: - core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala (91:105) - core/src/main/scala/kafka/controller/ControllerChannelManager.scala (149:163) duplicated block id: 42 size: 15 cleaned lines of code in 2 files: - streams/test-utils/src/main/java/org/apache/kafka/streams/internals/KeyValueStoreFacade.java (68:90) - streams/test-utils/src/main/java/org/apache/kafka/streams/internals/WindowStoreFacade.java (78:100) duplicated block id: 43 size: 15 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerRunning.java (43:63) - tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStopping.java (43:63) duplicated block id: 44 size: 15 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainSaslServer.java (156:176) - clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServer.java (127:147) duplicated block id: 45 size: 15 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java (192:214) - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java (157:179) duplicated block id: 46 size: 15 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java (70:89) - streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java (49:68) duplicated block id: 47 size: 15 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (135:149) - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (171:185) duplicated block id: 48 size: 15 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (173:187) - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (247:261) duplicated block id: 49 size: 15 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkTask.java (33:52) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceTask.java (32:51) duplicated block id: 50 size: 14 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServer.java (196:215) - clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java (154:173) - clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClient.java (124:143) duplicated block id: 51 size: 14 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (1494:1509) - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (2528:2543) duplicated block id: 52 size: 14 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java (75:91) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java (70:86) duplicated block id: 53 size: 14 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java (98:115) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java (79:96) duplicated block id: 54 size: 14 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala (46:66) - core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala (100:119) duplicated block id: 55 size: 14 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (137:150) - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (210:223) duplicated block id: 56 size: 14 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java (96:110) - tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java (69:83) duplicated block id: 57 size: 14 cleaned lines of code in 2 files: - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java (150:168) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java (92:110) duplicated block id: 58 size: 14 cleaned lines of code in 2 files: - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java (216:229) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java (160:173) duplicated block id: 59 size: 14 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java (238:257) - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java (245:264) duplicated block id: 60 size: 13 cleaned lines of code in 3 files: - core/src/main/scala/kafka/server/KafkaServer.scala (531:543) - core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala (91:103) - core/src/main/scala/kafka/controller/ControllerChannelManager.scala (149:161) duplicated block id: 61 size: 13 cleaned lines of code in 3 files: - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java (140:157) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java (93:110) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java (151:168) duplicated block id: 62 size: 13 cleaned lines of code in 3 files: - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java (144:156) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java (161:173) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java (217:229) duplicated block id: 63 size: 13 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (272:286) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (316:330) duplicated block id: 64 size: 13 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java (148:160) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (126:138) duplicated block id: 65 size: 13 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsResponse.java (48:68) - clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsResponse.java (48:68) duplicated block id: 66 size: 13 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java (105:121) - clients/src/main/java/org/apache/kafka/common/protocol/types/CompactArrayOf.java (111:127) duplicated block id: 67 size: 13 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java (138:150) - tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java (210:222) duplicated block id: 68 size: 13 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (215:230) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java (126:141) duplicated block id: 69 size: 13 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredLoginCallbackHandler.java (129:150) - clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredValidatorCallbackHandler.java (97:118) duplicated block id: 70 size: 13 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (78:97) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (91:110) duplicated block id: 71 size: 12 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java (58:69) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java (86:98) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java (116:127) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java (144:155) duplicated block id: 72 size: 12 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java (379:391) - clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java (163:174) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (487:499) duplicated block id: 73 size: 12 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java (138:154) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java (132:148) duplicated block id: 74 size: 12 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (1331:1347) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (1395:1411) duplicated block id: 75 size: 12 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java (151:164) - tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java (229:242) duplicated block id: 76 size: 12 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (160:174) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java (124:137) duplicated block id: 77 size: 12 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/plain/PlainLoginModule.java (46:63) - clients/src/main/java/org/apache/kafka/common/security/scram/ScramLoginModule.java (56:73) duplicated block id: 78 size: 12 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java (290:319) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java (1018:1047) duplicated block id: 79 size: 12 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java (434:446) - clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java (504:516) duplicated block id: 80 size: 12 cleaned lines of code in 2 files: - streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java (55:70) - streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java (228:243) duplicated block id: 81 size: 12 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java (235:246) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java (564:577) duplicated block id: 82 size: 12 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/StrictBufferConfigImpl.java (95:111) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/EagerBufferConfigImpl.java (80:96) duplicated block id: 83 size: 12 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java (87:98) - clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java (155:166) duplicated block id: 84 size: 12 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (193:208) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (462:477) duplicated block id: 85 size: 12 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java (353:364) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (455:466) duplicated block id: 86 size: 12 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (330:348) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java (219:237) duplicated block id: 87 size: 12 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (1244:1256) - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (1290:1302) duplicated block id: 88 size: 12 cleaned lines of code in 2 files: - connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java (116:127) - connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java (587:598) duplicated block id: 89 size: 11 cleaned lines of code in 5 files: - streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java (60:73) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java (97:110) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java (144:157) - streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java (112:125) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java (155:168) duplicated block id: 90 size: 11 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (261:275) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java (134:148) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (248:262) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (162:176) duplicated block id: 91 size: 11 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java (43:59) - clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java (74:90) - clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java (73:89) duplicated block id: 92 size: 11 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (835:846) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (876:887) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (915:926) duplicated block id: 93 size: 11 cleaned lines of code in 3 files: - tools/src/main/java/org/apache/kafka/trogdor/fault/Kibosh.java (48:62) - tools/src/main/java/org/apache/kafka/trogdor/rest/Message.java (25:39) - tools/src/main/java/org/apache/kafka/trogdor/fault/Kibosh.java (148:162) duplicated block id: 94 size: 11 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java (80:95) - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java (114:129) duplicated block id: 95 size: 11 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/ApiMessageTypeGenerator.java (202:213) - generator/src/main/java/org/apache/kafka/message/ApiMessageTypeGenerator.java (316:327) duplicated block id: 96 size: 11 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java (56:73) - clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java (50:66) duplicated block id: 97 size: 11 cleaned lines of code in 2 files: - core/src/main/scala/kafka/admin/LeaderElectionCommand.scala (96:106) - core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala (89:99) duplicated block id: 98 size: 11 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java (185:197) - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java (192:204) duplicated block id: 99 size: 11 cleaned lines of code in 2 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java (274:289) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java (117:132) duplicated block id: 100 size: 11 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (278:291) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (345:357) duplicated block id: 101 size: 11 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java (41:55) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java (39:53) duplicated block id: 102 size: 11 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (1615:1632) - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (2536:2553) duplicated block id: 103 size: 11 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java (44:59) - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java (65:80) duplicated block id: 104 size: 11 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (150:160) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (382:392) duplicated block id: 105 size: 11 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java (268:278) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java (291:301) duplicated block id: 106 size: 11 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (648:661) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (698:711) duplicated block id: 107 size: 11 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (214:226) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (260:273) duplicated block id: 108 size: 11 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java (100:113) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java (129:142) duplicated block id: 109 size: 11 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosClientCallbackHandler.java (56:66) - clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientCallbackHandler.java (73:84) duplicated block id: 110 size: 11 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java (134:146) - tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java (100:112) duplicated block id: 111 size: 10 cleaned lines of code in 6 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (215:226) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (248:260) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java (134:146) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java (126:137) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (162:174) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (261:273) duplicated block id: 112 size: 10 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java (85:95) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (80:90) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (81:91) duplicated block id: 113 size: 10 cleaned lines of code in 3 files: - tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java (176:185) - tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java (229:238) - tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java (151:160) duplicated block id: 114 size: 10 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/common/TopicPartition.java (53:64) - clients/src/main/java/org/apache/kafka/common/TopicPartitionReplica.java (61:72) - clients/src/main/java/org/apache/kafka/common/MetricName.java (111:122) duplicated block id: 115 size: 10 cleaned lines of code in 3 files: - generator/src/main/java/org/apache/kafka/message/VersionConditional.java (90:100) - generator/src/main/java/org/apache/kafka/message/VersionConditional.java (115:125) - generator/src/main/java/org/apache/kafka/message/VersionConditional.java (139:149) duplicated block id: 116 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java (76:88) - streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java (142:154) duplicated block id: 117 size: 10 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java (325:334) - tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java (248:257) duplicated block id: 118 size: 10 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpec.java (138:153) - tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java (120:135) duplicated block id: 119 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (93:103) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java (80:90) duplicated block id: 120 size: 10 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (759:771) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (824:836) duplicated block id: 121 size: 10 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java (139:148) - clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java (166:175) duplicated block id: 122 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMaterializedValueGetterSupplier.java (40:54) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java (125:139) duplicated block id: 123 size: 10 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (428:437) - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (692:701) duplicated block id: 124 size: 10 cleaned lines of code in 2 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (182:191) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (230:239) duplicated block id: 125 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (195:204) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (282:291) duplicated block id: 126 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java (143:160) - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java (535:552) duplicated block id: 127 size: 10 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java (87:96) - clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java (494:503) duplicated block id: 128 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java (195:206) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java (210:221) duplicated block id: 129 size: 10 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java (46:61) - clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java (54:69) duplicated block id: 130 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java (73:89) - streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java (72:88) duplicated block id: 131 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java (151:161) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java (83:93) duplicated block id: 132 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplier.java (63:72) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java (60:70) duplicated block id: 133 size: 10 cleaned lines of code in 2 files: - streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java (247:260) - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java (175:188) duplicated block id: 134 size: 10 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/serialization/UUIDSerializer.java (30:42) - clients/src/main/java/org/apache/kafka/common/serialization/StringSerializer.java (29:41) duplicated block id: 135 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (322:332) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (366:376) duplicated block id: 136 size: 10 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java (478:487) - clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java (493:502) duplicated block id: 137 size: 10 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java (128:139) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java (115:125) duplicated block id: 138 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java (117:132) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java (91:106) duplicated block id: 139 size: 10 cleaned lines of code in 2 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java (124:136) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (128:140) duplicated block id: 140 size: 10 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java (233:245) - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java (595:607) duplicated block id: 141 size: 10 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java (115:124) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java (146:155) duplicated block id: 142 size: 10 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (414:423) - streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java (791:800) duplicated block id: 143 size: 9 cleaned lines of code in 10 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (171:179) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (191:199) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (211:219) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (231:239) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (251:259) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (271:279) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (291:299) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (311:319) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (331:339) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (351:359) duplicated block id: 144 size: 9 cleaned lines of code in 7 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (274:286) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java (217:229) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java (110:122) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (260:272) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java (447:459) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java (310:322) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java (105:117) duplicated block id: 145 size: 9 cleaned lines of code in 7 files: - streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java (150:158) - streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java (172:180) - streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java (189:197) - streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java (206:214) - streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java (223:231) - streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java (243:251) - streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java (263:271) duplicated block id: 146 size: 9 cleaned lines of code in 7 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (257:269) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java (198:210) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java (93:105) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (241:253) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java (430:442) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java (293:305) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java (88:100) duplicated block id: 147 size: 9 cleaned lines of code in 6 files: - streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java (233:243) - streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java (112:122) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java (144:154) - streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java (60:70) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java (155:165) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java (97:107) duplicated block id: 148 size: 9 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java (138:150) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java (133:145) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java (129:141) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java (132:144) duplicated block id: 149 size: 9 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java (49:61) - clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsResponse.java (56:68) - clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java (43:55) - clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java (107:119) duplicated block id: 150 size: 9 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsResponse.java (48:62) - clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsResponse.java (48:62) - clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsResponse.java (48:62) - clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsResponse.java (50:64) duplicated block id: 151 size: 9 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java (51:63) - clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java (73:85) - clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java (43:55) - clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java (74:86) duplicated block id: 152 size: 9 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/MetricName.java (112:122) - clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java (557:567) - clients/src/main/java/org/apache/kafka/common/TopicPartition.java (54:64) - clients/src/main/java/org/apache/kafka/common/TopicPartitionReplica.java (62:72) duplicated block id: 153 size: 9 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (173:186) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (145:156) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (192:205) duplicated block id: 154 size: 9 cleaned lines of code in 3 files: - core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala (81:89) - core/src/main/scala/kafka/controller/ControllerChannelManager.scala (155:163) - core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala (97:105) duplicated block id: 155 size: 9 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java (152:164) - clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataRequest.java (173:185) - clients/src/main/java/org/apache/kafka/common/requests/StopReplicaRequest.java (198:210) duplicated block id: 156 size: 9 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java (91:99) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java (84:92) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (90:98) duplicated block id: 157 size: 9 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (84:97) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (96:108) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (97:110) duplicated block id: 158 size: 9 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GroupedTableOperationRepartitionNode.java (91:100) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java (69:78) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java (83:92) duplicated block id: 159 size: 9 cleaned lines of code in 3 files: - connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceConnector.java (33:46) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkConnector.java (33:46) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceConnector.java (31:44) duplicated block id: 160 size: 9 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (145:159) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (117:131) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (162:178) duplicated block id: 161 size: 9 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java (57:71) - clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java (54:68) - clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java (46:60) duplicated block id: 162 size: 9 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java (110:118) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java (53:61) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java (91:99) duplicated block id: 163 size: 9 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java (266:274) - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (871:879) duplicated block id: 164 size: 9 cleaned lines of code in 2 files: - connect/api/src/main/java/org/apache/kafka/connect/data/Time.java (35:58) - connect/api/src/main/java/org/apache/kafka/connect/data/Date.java (35:58) duplicated block id: 165 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java (36:44) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java (39:47) duplicated block id: 166 size: 9 cleaned lines of code in 2 files: - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java (146:155) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java (109:117) duplicated block id: 167 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java (229:238) - clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java (249:258) duplicated block id: 168 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (126:134) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (157:165) duplicated block id: 169 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/resource/ResourceFilter.java (102:115) - clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java (127:140) duplicated block id: 170 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (688:698) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (813:824) duplicated block id: 171 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (371:379) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (391:399) duplicated block id: 172 size: 9 cleaned lines of code in 2 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (67:77) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (125:135) duplicated block id: 173 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (408:418) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (516:526) duplicated block id: 174 size: 9 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java (201:211) - tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java (169:179) duplicated block id: 175 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java (103:124) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java (244:264) duplicated block id: 176 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (638:648) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (749:759) duplicated block id: 177 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (411:419) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (430:438) duplicated block id: 178 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java (58:67) - streams/src/main/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestamp.java (56:65) duplicated block id: 179 size: 9 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkConnector.java (70:82) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceConnector.java (70:82) duplicated block id: 180 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java (170:180) - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java (177:187) duplicated block id: 181 size: 9 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java (122:130) - tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java (507:515) duplicated block id: 182 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java (151:163) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java (160:172) duplicated block id: 183 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java (317:325) - clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java (259:267) duplicated block id: 184 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java (87:95) - clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java (479:487) duplicated block id: 185 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java (683:691) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java (707:716) duplicated block id: 186 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (878:886) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (924:932) duplicated block id: 187 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (784:796) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (850:862) duplicated block id: 188 size: 9 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java (91:99) - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (430:438) duplicated block id: 189 size: 9 cleaned lines of code in 2 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (118:126) - connect/api/src/main/java/org/apache/kafka/connect/data/Schema.java (119:127) duplicated block id: 190 size: 9 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala (158:166) - core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala (204:212) duplicated block id: 191 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (127:141) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (230:244) duplicated block id: 192 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (344:352) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (365:374) duplicated block id: 193 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (414:422) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (447:455) duplicated block id: 194 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (912:924) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (973:985) duplicated block id: 195 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java (230:239) - streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java (415:425) duplicated block id: 196 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (281:290) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (433:443) duplicated block id: 197 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/network/Selector.java (149:157) - clients/src/main/java/org/apache/kafka/common/network/Selector.java (189:197) duplicated block id: 198 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java (662:670) - clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java (691:699) duplicated block id: 199 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (53:63) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (55:65) duplicated block id: 200 size: 9 cleaned lines of code in 2 files: - streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionConversions.scala (34:46) - streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionsCompatConversions.scala (37:49) duplicated block id: 201 size: 9 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (928:937) - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (1222:1231) duplicated block id: 202 size: 9 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStopping.java (36:48) - tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRunning.java (36:48) duplicated block id: 203 size: 9 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java (723:732) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java (885:894) duplicated block id: 204 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosClientCallbackHandler.java (43:51) - clients/src/main/java/org/apache/kafka/common/security/authenticator/AbstractLogin.java (91:99) duplicated block id: 205 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java (79:91) - streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java (85:97) duplicated block id: 206 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegment.java (30:42) - streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegment.java (30:42) duplicated block id: 207 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java (151:166) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java (262:277) duplicated block id: 208 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java (60:72) - clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java (80:92) duplicated block id: 209 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java (54:67) - streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java (64:77) duplicated block id: 210 size: 9 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java (250:261) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java (587:598) duplicated block id: 211 size: 9 cleaned lines of code in 2 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java (76:90) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (223:237) duplicated block id: 212 size: 9 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala (206:214) - core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala (248:256) duplicated block id: 213 size: 9 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (2145:2158) - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (2208:2221) duplicated block id: 214 size: 8 cleaned lines of code in 10 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (260:267) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (277:284) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (294:301) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (311:318) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (346:353) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (363:370) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (380:387) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (431:438) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (448:455) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (465:472) duplicated block id: 215 size: 8 cleaned lines of code in 9 files: - streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java (66:75) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java (97:106) - streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java (60:69) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java (155:164) - streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java (57:66) - streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java (233:242) - streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java (112:121) - streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java (52:61) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java (144:153) duplicated block id: 216 size: 8 cleaned lines of code in 5 files: - clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java (49:60) - clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java (80:91) - clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java (82:93) - clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java (60:71) - clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java (57:68) duplicated block id: 217 size: 8 cleaned lines of code in 5 files: - clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java (91:98) - clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java (560:567) - clients/src/main/java/org/apache/kafka/common/MetricName.java (115:122) - clients/src/main/java/org/apache/kafka/common/TopicPartition.java (57:64) - clients/src/main/java/org/apache/kafka/common/TopicPartitionReplica.java (65:72) duplicated block id: 218 size: 8 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (139:146) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (186:193) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (207:214) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (227:234) duplicated block id: 219 size: 8 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStore.java (53:60) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java (54:61) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java (111:118) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java (92:99) duplicated block id: 220 size: 8 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java (76:87) - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java (96:107) - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java (114:125) - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java (132:143) duplicated block id: 221 size: 8 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (206:213) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (224:231) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (242:249) duplicated block id: 222 size: 8 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GroupedTableOperationRepartitionNode.java (40:47) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java (39:46) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java (36:43) duplicated block id: 223 size: 8 cleaned lines of code in 3 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (70:77) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java (124:131) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (128:135) duplicated block id: 224 size: 8 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (48:55) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (52:59) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (53:60) duplicated block id: 225 size: 8 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java (68:79) - clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java (55:66) - clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java (62:73) duplicated block id: 226 size: 8 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java (44:53) - streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializer.java (42:51) - streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java (43:52) duplicated block id: 227 size: 8 cleaned lines of code in 3 files: - connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java (51:58) - connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java (106:113) - connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java (71:78) duplicated block id: 228 size: 8 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java (97:104) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (92:99) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (93:100) duplicated block id: 229 size: 8 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (57:70) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (62:75) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (62:76) duplicated block id: 230 size: 8 cleaned lines of code in 3 files: - connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Checkpoint.java (108:117) - connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSync.java (74:83) - connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Heartbeat.java (82:91) duplicated block id: 231 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java (52:63) - clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java (44:55) duplicated block id: 232 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java (190:201) - clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java (90:101) duplicated block id: 233 size: 8 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java (268:275) - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (1191:1198) duplicated block id: 234 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java (115:124) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (112:122) duplicated block id: 235 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (437:446) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (488:497) duplicated block id: 236 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/StrictBufferConfigImpl.java (70:81) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/EagerBufferConfigImpl.java (55:66) duplicated block id: 237 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java (204:211) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java (282:289) duplicated block id: 238 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntry.java (56:78) - clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryFilter.java (65:87) duplicated block id: 239 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java (700:707) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java (749:756) duplicated block id: 240 size: 8 cleaned lines of code in 2 files: - core/src/main/scala/kafka/log/LogCleanerManager.scala (424:431) - core/src/main/scala/kafka/log/LogCleanerManager.scala (442:449) duplicated block id: 241 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java (60:71) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java (67:77) duplicated block id: 242 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/network/Selector.java (146:153) - clients/src/main/java/org/apache/kafka/common/network/Selector.java (202:209) duplicated block id: 243 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java (593:601) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java (629:637) duplicated block id: 244 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsForLeaderEpochClient.java (82:89) - clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java (1048:1055) duplicated block id: 245 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/Topology.java (751:758) - streams/src/main/java/org/apache/kafka/streams/Topology.java (839:846) duplicated block id: 246 size: 8 cleaned lines of code in 2 files: - core/src/main/scala/kafka/log/OffsetIndex.scala (170:177) - core/src/main/scala/kafka/log/TimeIndex.scala (178:185) duplicated block id: 247 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (670:679) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (721:730) duplicated block id: 248 size: 8 cleaned lines of code in 2 files: - core/src/main/scala/kafka/server/AdminManager.scala (479:487) - core/src/main/scala/kafka/server/AdminManager.scala (605:613) duplicated block id: 249 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (2750:2761) - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (2784:2795) duplicated block id: 250 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseRepartitionNode.java (38:45) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java (31:38) duplicated block id: 251 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (864:871) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (910:917) duplicated block id: 252 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java (177:194) - clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java (87:98) duplicated block id: 253 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java (63:76) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java (68:81) duplicated block id: 254 size: 8 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java (141:148) - tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java (77:84) duplicated block id: 255 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java (75:84) - clients/src/main/java/org/apache/kafka/common/protocol/types/CompactArrayOf.java (80:89) duplicated block id: 256 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (546:555) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (630:639) duplicated block id: 257 size: 8 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java (336:345) - tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java (259:268) duplicated block id: 258 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java (271:282) - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java (276:287) duplicated block id: 259 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (568:577) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (803:812) duplicated block id: 260 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java (213:287) - streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java (164:238) duplicated block id: 261 size: 8 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java (112:121) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java (207:215) duplicated block id: 262 size: 8 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java (465:474) - connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java (164:174) duplicated block id: 263 size: 8 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java (365:376) - tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java (411:422) duplicated block id: 264 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/Topology.java (796:803) - streams/src/main/java/org/apache/kafka/streams/Topology.java (884:891) duplicated block id: 265 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbSessionBytesStoreSupplier.java (28:39) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionBytesStoreSupplier.java (28:39) duplicated block id: 266 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (854:862) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (894:901) duplicated block id: 267 size: 8 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java (109:118) - connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java (392:401) duplicated block id: 268 size: 8 cleaned lines of code in 2 files: - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java (145:152) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java (149:156) duplicated block id: 269 size: 8 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala (47:54) - core/src/main/scala/kafka/server/KafkaServer.scala (508:515) duplicated block id: 270 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java (84:93) - clients/src/main/java/org/apache/kafka/common/internals/Topic.java (77:87) duplicated block id: 271 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java (38:85) - streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java (49:96) duplicated block id: 272 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java (295:302) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (321:328) duplicated block id: 273 size: 8 cleaned lines of code in 2 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java (148:160) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (160:172) duplicated block id: 274 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (240:249) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (257:266) duplicated block id: 275 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java (151:158) - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java (147:154) duplicated block id: 276 size: 8 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (540:547) - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (792:799) duplicated block id: 277 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (280:289) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (316:325) duplicated block id: 278 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (482:489) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (500:507) duplicated block id: 279 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (1606:1613) - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (2527:2534) duplicated block id: 280 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/plain/PlainLoginModule.java (36:43) - clients/src/main/java/org/apache/kafka/common/security/scram/ScramLoginModule.java (40:47) duplicated block id: 281 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java (39:48) - streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java (55:64) duplicated block id: 282 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java (1012:1023) - clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java (1046:1057) duplicated block id: 283 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java (55:67) - streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java (54:66) duplicated block id: 284 size: 8 cleaned lines of code in 2 files: - core/src/main/scala/kafka/server/ReplicaManager.scala (1154:1161) - core/src/main/scala/kafka/server/ReplicaManager.scala (1170:1177) duplicated block id: 285 size: 8 cleaned lines of code in 2 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (81:94) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java (72:85) duplicated block id: 286 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/Topology.java (746:753) - streams/src/main/java/org/apache/kafka/streams/Topology.java (791:798) duplicated block id: 287 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java (65:73) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java (60:68) duplicated block id: 288 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java (131:142) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java (150:161) duplicated block id: 289 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java (231:240) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (90:98) duplicated block id: 290 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java (87:98) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java (65:76) duplicated block id: 291 size: 8 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/converters/ByteArrayConverter.java (68:79) - connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverter.java (95:106) duplicated block id: 292 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/Topology.java (834:841) - streams/src/main/java/org/apache/kafka/streams/Topology.java (879:886) duplicated block id: 293 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java (70:81) - streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java (80:91) duplicated block id: 294 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java (204:212) - clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java (359:367) duplicated block id: 295 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java (43:54) - clients/src/main/java/org/apache/kafka/common/protocol/types/CompactArrayOf.java (46:57) duplicated block id: 296 size: 8 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala (282:290) - core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala (429:437) duplicated block id: 297 size: 8 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (397:404) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (414:421) duplicated block id: 298 size: 8 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (456:465) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (578:588) duplicated block id: 299 size: 7 cleaned lines of code in 8 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java (193:203) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (260:270) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (274:284) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java (110:120) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java (217:227) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java (310:320) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java (105:115) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java (447:457) duplicated block id: 300 size: 7 cleaned lines of code in 8 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java (176:186) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (241:251) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (257:267) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java (93:103) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java (198:208) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java (293:303) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java (88:98) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java (430:440) duplicated block id: 301 size: 7 cleaned lines of code in 5 files: - tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java (177:183) - tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java (232:238) - tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java (179:185) - tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java (220:226) - tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java (154:160) duplicated block id: 302 size: 7 cleaned lines of code in 5 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java (93:99) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java (55:61) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java (112:118) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStore.java (54:60) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java (93:99) duplicated block id: 303 size: 7 cleaned lines of code in 5 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java (51:59) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java (75:83) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java (77:85) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java (76:84) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java (74:82) duplicated block id: 304 size: 7 cleaned lines of code in 5 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedKeyValueStoreMaterializer.java (47:56) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (266:275) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java (139:148) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (253:262) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (167:176) duplicated block id: 305 size: 7 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java (46:56) - clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java (112:122) - clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java (54:64) - clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java (57:67) duplicated block id: 306 size: 7 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java (47:53) - streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java (61:67) - streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializer.java (45:51) - streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java (46:52) duplicated block id: 307 size: 7 cleaned lines of code in 4 files: - connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java (102:108) - connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java (230:236) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (551:557) - connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java (128:134) duplicated block id: 308 size: 7 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java (65:75) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java (219:229) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (330:340) - streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java (87:97) duplicated block id: 309 size: 7 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java (56:67) - clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java (44:54) - clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java (52:62) - clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java (50:60) duplicated block id: 310 size: 7 cleaned lines of code in 4 files: - connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverter.java (114:124) - connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java (330:340) - connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverter.java (95:105) - connect/runtime/src/main/java/org/apache/kafka/connect/converters/ByteArrayConverter.java (68:78) duplicated block id: 311 size: 7 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java (295:301) - clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java (204:210) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java (282:288) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (321:327) duplicated block id: 312 size: 7 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsRequest.java (73:86) - clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsRequest.java (69:82) - clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsRequest.java (76:89) - clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsRequest.java (77:90) duplicated block id: 313 size: 7 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java (86:92) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java (80:86) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java (85:91) duplicated block id: 314 size: 7 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java (275:282) - streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java (251:258) - streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java (146:153) duplicated block id: 315 size: 7 cleaned lines of code in 3 files: - connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceConnector.java (56:67) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkConnector.java (56:67) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceConnector.java (54:65) duplicated block id: 316 size: 7 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java (555:567) - clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java (239:251) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (641:653) duplicated block id: 317 size: 7 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (420:428) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (470:478) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (528:536) duplicated block id: 318 size: 7 cleaned lines of code in 3 files: - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java (109:115) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java (150:156) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java (146:152) duplicated block id: 319 size: 7 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (127:133) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (136:142) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (158:164) duplicated block id: 320 size: 7 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (133:141) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (203:213) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (149:158) duplicated block id: 321 size: 7 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (107:113) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (123:129) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (273:279) duplicated block id: 322 size: 7 cleaned lines of code in 3 files: - generator/src/main/java/org/apache/kafka/message/FieldType.java (187:197) - generator/src/main/java/org/apache/kafka/message/FieldType.java (218:228) - generator/src/main/java/org/apache/kafka/message/FieldType.java (249:259) duplicated block id: 323 size: 7 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java (50:56) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java (46:52) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (51:57) duplicated block id: 324 size: 7 cleaned lines of code in 3 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java (103:113) - tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java (155:165) - tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpec.java (163:173) duplicated block id: 325 size: 7 cleaned lines of code in 3 files: - connect/api/src/main/java/org/apache/kafka/connect/data/Schema.java (119:125) - connect/api/src/main/java/org/apache/kafka/connect/data/SchemaProjector.java (82:88) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (118:124) duplicated block id: 326 size: 7 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java (66:75) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java (59:68) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java (286:295) duplicated block id: 327 size: 7 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java (107:116) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java (63:74) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java (68:79) duplicated block id: 328 size: 7 cleaned lines of code in 3 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java (78:88) - tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java (120:130) - tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpec.java (138:148) duplicated block id: 329 size: 7 cleaned lines of code in 3 files: - tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java (104:110) - tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java (141:147) - tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java (77:83) duplicated block id: 330 size: 7 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/Consumed.java (208:217) - streams/src/main/java/org/apache/kafka/streams/processor/To.java (68:77) - streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java (174:183) duplicated block id: 331 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java (439:447) - clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java (462:470) duplicated block id: 332 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (113:122) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (107:116) duplicated block id: 333 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java (167:174) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java (151:158) duplicated block id: 334 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/zk/ZkData.scala (407:415) - core/src/main/scala/kafka/zk/ZkData.scala (500:507) duplicated block id: 335 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesStore.java (32:38) - streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueBytesStore.java (31:37) duplicated block id: 336 size: 7 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (464:474) - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (895:905) duplicated block id: 337 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java (351:357) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java (301:307) duplicated block id: 338 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (871:879) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (886:894) duplicated block id: 339 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java (647:655) - clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java (543:551) duplicated block id: 340 size: 7 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java (401:410) - tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java (327:336) duplicated block id: 341 size: 7 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionSpec.java (118:128) - tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java (73:83) duplicated block id: 342 size: 7 cleaned lines of code in 2 files: - connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkConnector.java (44:52) - connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java (54:62) duplicated block id: 343 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java (86:95) - streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java (102:120) duplicated block id: 344 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/Topology.java (755:761) - streams/src/main/java/org/apache/kafka/streams/Topology.java (800:806) duplicated block id: 345 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java (159:167) - clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java (52:60) duplicated block id: 346 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/Topology.java (843:849) - streams/src/main/java/org/apache/kafka/streams/Topology.java (888:894) duplicated block id: 347 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClient.java (110:117) - clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java (142:150) duplicated block id: 348 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/RecordsSend.java (43:53) - clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java (43:53) duplicated block id: 349 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (176:184) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (251:261) duplicated block id: 350 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java (76:82) - streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java (99:105) duplicated block id: 351 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java (62:73) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java (69:77) duplicated block id: 352 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java (425:431) - clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiCollection.java (69:75) duplicated block id: 353 size: 7 cleaned lines of code in 2 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (144:153) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (178:187) duplicated block id: 354 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java (247:257) - clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java (58:68) duplicated block id: 355 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java (262:268) - streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java (315:321) duplicated block id: 356 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java (93:103) - clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java (58:68) duplicated block id: 357 size: 7 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/TaskInfo.java (39:47) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequest.java (40:48) duplicated block id: 358 size: 7 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (873:879) - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (1191:1197) duplicated block id: 359 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java (175:185) - clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java (565:575) duplicated block id: 360 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (121:129) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java (110:118) duplicated block id: 361 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/serialization/UUIDDeserializer.java (30:37) - clients/src/main/java/org/apache/kafka/common/serialization/StringDeserializer.java (29:36) duplicated block id: 362 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java (195:205) - clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java (575:585) duplicated block id: 363 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java (117:124) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java (252:259) duplicated block id: 364 size: 7 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java (197:204) - tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java (241:248) duplicated block id: 365 size: 7 cleaned lines of code in 2 files: - streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedKStream.scala (75:92) - streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedKStream.scala (71:88) duplicated block id: 366 size: 7 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java (88:94) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java (70:76) duplicated block id: 367 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (307:313) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (457:463) duplicated block id: 368 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/network/Selector.java (187:193) - clients/src/main/java/org/apache/kafka/common/network/Selector.java (215:221) duplicated block id: 369 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala (68:74) - core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala (78:84) duplicated block id: 370 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (105:111) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java (209:216) duplicated block id: 371 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (429:435) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java (289:295) duplicated block id: 372 size: 7 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionSpec.java (148:158) - tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java (135:145) duplicated block id: 373 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java (286:293) - streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java (349:356) duplicated block id: 374 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java (986:992) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java (1011:1017) duplicated block id: 375 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java (224:233) - clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java (106:115) duplicated block id: 376 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java (37:43) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java (107:113) duplicated block id: 377 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java (202:210) - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java (219:227) duplicated block id: 378 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (154:160) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (125:131) duplicated block id: 379 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (917:925) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (932:940) duplicated block id: 380 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (205:212) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (233:240) duplicated block id: 381 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/server/FetchSession.scala (327:338) - core/src/main/scala/kafka/server/FetchSession.scala (358:369) duplicated block id: 382 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java (210:218) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java (231:239) duplicated block id: 383 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/Topology.java (877:883) - streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java (543:549) duplicated block id: 384 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java (88:97) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java (97:106) duplicated block id: 385 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java (105:114) - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java (91:100) duplicated block id: 386 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (151:157) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (251:257) duplicated block id: 387 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java (55:63) - clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java (57:65) duplicated block id: 388 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (319:325) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (354:360) duplicated block id: 389 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java (366:373) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java (400:407) duplicated block id: 390 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegment.java (44:55) - streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegment.java (44:55) duplicated block id: 391 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (162:168) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (133:139) duplicated block id: 392 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/resource/Resource.java (78:91) - clients/src/main/java/org/apache/kafka/common/resource/ResourceFilter.java (65:78) duplicated block id: 393 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java (78:84) - clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsResponse.java (51:57) duplicated block id: 394 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java (41:47) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java (95:101) duplicated block id: 395 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java (67:78) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java (74:82) duplicated block id: 396 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/log/LogValidator.scala (81:87) - core/src/main/scala/kafka/log/LogValidator.scala (343:349) duplicated block id: 397 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java (41:49) - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java (48:56) duplicated block id: 398 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java (758:764) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java (132:138) duplicated block id: 399 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredLoginCallbackHandler.java (152:160) - clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientCallbackHandler.java (74:82) duplicated block id: 400 size: 7 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java (77:85) - tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java (131:139) duplicated block id: 401 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala (1196:1202) - core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala (1222:1228) duplicated block id: 402 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/config/ConfigValue.java (99:105) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigValueInfo.java (91:97) duplicated block id: 403 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java (211:217) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java (231:237) duplicated block id: 404 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala (827:834) - core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala (841:848) duplicated block id: 405 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java (424:432) - clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java (437:445) duplicated block id: 406 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java (1000:1009) - clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java (1034:1043) duplicated block id: 407 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/Topology.java (345:371) - streams/src/main/java/org/apache/kafka/streams/Topology.java (374:403) duplicated block id: 408 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala (218:226) - core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala (247:255) duplicated block id: 409 size: 7 cleaned lines of code in 2 files: - connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkConnector.java (67:79) - connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java (85:96) duplicated block id: 410 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java (225:232) - streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java (305:315) duplicated block id: 411 size: 7 cleaned lines of code in 2 files: - connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java (111:121) - connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java (176:186) duplicated block id: 412 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala (473:479) - core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala (83:89) duplicated block id: 413 size: 7 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/rest/ErrorResponse.java (45:53) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ErrorMessage.java (44:52) duplicated block id: 414 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/zk/KafkaZkClient.scala (407:413) - core/src/main/scala/kafka/zk/KafkaZkClient.scala (426:432) duplicated block id: 415 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java (87:93) - clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java (466:472) duplicated block id: 416 size: 7 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java (421:429) - connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java (442:449) duplicated block id: 417 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionSendProcessorSupplier.java (115:121) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionSendProcessorSupplier.java (154:160) duplicated block id: 418 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java (81:87) - clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java (100:106) duplicated block id: 419 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/network/Selector.java (205:211) - clients/src/main/java/org/apache/kafka/common/network/Selector.java (217:223) duplicated block id: 420 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (371:379) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (405:413) duplicated block id: 421 size: 7 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java (487:493) - connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java (193:199) duplicated block id: 422 size: 7 cleaned lines of code in 2 files: - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java (87:95) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java (96:104) duplicated block id: 423 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java (73:79) - clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java (92:98) duplicated block id: 424 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java (338:344) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (497:503) duplicated block id: 425 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java (348:356) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java (374:383) duplicated block id: 426 size: 7 cleaned lines of code in 2 files: - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java (106:113) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java (125:132) duplicated block id: 427 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImpl.java (103:111) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImpl.java (116:124) duplicated block id: 428 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala (311:319) - core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala (588:596) duplicated block id: 429 size: 7 cleaned lines of code in 2 files: - streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java (585:591) - streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java (642:648) duplicated block id: 430 size: 7 cleaned lines of code in 2 files: - connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java (306:318) - connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java (324:335) duplicated block id: 431 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplier.java (82:88) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java (113:119) duplicated block id: 432 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java (1765:1774) - streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java (1936:1945) duplicated block id: 433 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala (81:87) - core/src/main/scala/kafka/server/KafkaServer.scala (537:543) duplicated block id: 434 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerde.java (123:129) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java (143:149) duplicated block id: 435 size: 7 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java (55:61) - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java (65:71) duplicated block id: 436 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java (52:62) - clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java (53:63) duplicated block id: 437 size: 7 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java (133:139) - tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java (517:523) duplicated block id: 438 size: 7 cleaned lines of code in 2 files: - streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java (448:454) - streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java (514:520) duplicated block id: 439 size: 7 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java (91:101) - clients/src/main/java/org/apache/kafka/common/protocol/types/CompactArrayOf.java (96:107) duplicated block id: 440 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala (94:100) - core/src/main/scala/kafka/controller/ControllerChannelManager.scala (158:164) duplicated block id: 441 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala (661:668) - core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala (677:684) duplicated block id: 442 size: 6 cleaned lines of code in 33 files: - streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java (49:55) - streams/src/main/java/org/apache/kafka/streams/state/internals/ContextualRecord.java (54:60) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/FinalResultsSuppressionBuilder.java (49:55) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/Change.java (36:42) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/SuppressedInternal.java (87:93) - streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java (276:282) - streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java (61:67) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/StrictBufferConfigImpl.java (105:111) - streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java (190:196) - streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java (252:258) - streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.java (79:85) - streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java (76:82) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java (72:78) - streams/src/main/java/org/apache/kafka/streams/state/internals/BufferKey.java (40:46) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StaticTopicNameExtractor.java (44:50) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/EagerBufferConfigImpl.java (90:96) - streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java (122:128) - streams/src/main/java/org/apache/kafka/streams/processor/To.java (71:77) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (183:189) - streams/src/main/java/org/apache/kafka/streams/kstream/Consumed.java (211:217) - streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java (1486:1492) - streams/src/main/java/org/apache/kafka/streams/processor/ThreadMetadata.java (98:104) - streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java (177:183) - streams/src/main/java/org/apache/kafka/streams/state/ValueAndTimestamp.java (78:84) - streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java (115:121) - streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java (194:200) - streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java (147:153) - streams/src/main/java/org/apache/kafka/streams/state/HostInfo.java (80:86) - streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.java (315:321) - streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java (71:77) - streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java (1591:1597) - streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java (1636:1642) - streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java (1706:1712) duplicated block id: 443 size: 6 cleaned lines of code in 27 files: - clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java (95:100) - connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java (77:82) - connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java (106:111) - clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java (88:93) - connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java (86:91) - clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java (222:227) - clients/src/main/java/org/apache/kafka/clients/admin/Config.java (60:65) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java (58:63) - clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java (164:169) - clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java (434:439) - clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java (162:167) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java (127:132) - clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java (153:158) - connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java (51:56) - connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java (71:76) - clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java (285:290) - connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java (49:54) - clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java (91:96) - connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java (151:156) - clients/src/main/java/org/apache/kafka/common/record/FileRecords.java (474:479) - clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java (55:60) - clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java (114:119) - clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java (393:398) - clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java (102:107) - clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java (260:265) - clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java (522:527) - clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java (187:192) duplicated block id: 444 size: 6 cleaned lines of code in 22 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (515:520) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (527:532) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (539:544) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (551:556) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (563:568) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (575:580) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (587:592) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (599:604) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (611:616) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (623:628) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (635:640) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (647:652) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (659:664) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (671:676) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (683:688) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (695:700) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (707:712) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (719:724) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (731:736) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (743:748) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (755:760) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java (767:772) duplicated block id: 445 size: 6 cleaned lines of code in 14 files: - clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java (57:64) - clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsResponse.java (51:58) - clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java (60:67) - clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java (115:122) - clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java (82:89) - clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java (49:56) - clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java (56:63) - clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java (48:55) - clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java (78:85) - clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java (80:87) - clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java (39:46) - clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java (57:64) - clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java (79:86) - clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java (86:93) duplicated block id: 446 size: 6 cleaned lines of code in 8 files: - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/TopicBenchmark.java (33:38) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java (62:67) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchResponseBenchmark.java (51:56) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/MetadataRequestBenchmark.java (78:83) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRecordBenchmark.java (33:38) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java (70:75) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java (91:96) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchRequestBenchmark.java (48:53) duplicated block id: 447 size: 6 cleaned lines of code in 7 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java (107:115) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java (70:77) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java (68:78) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java (97:105) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java (88:96) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java (75:82) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java (63:73) duplicated block id: 448 size: 6 cleaned lines of code in 7 files: - clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java (74:81) - clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java (59:66) - clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java (43:50) - clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java (66:73) - clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java (72:79) - clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java (73:80) - clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java (51:58) duplicated block id: 449 size: 6 cleaned lines of code in 6 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedKeyValueStoreMaterializer.java (47:54) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (220:226) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (167:174) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java (131:137) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java (139:146) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (266:273) duplicated block id: 450 size: 6 cleaned lines of code in 6 files: - clients/src/main/java/org/apache/kafka/common/security/token/delegation/TokenInformation.java (106:112) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorPluginInfo.java (61:67) - clients/src/main/java/org/apache/kafka/common/security/token/delegation/DelegationToken.java (51:57) - clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java (464:470) - clients/src/main/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPool.java (136:142) - clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java (149:155) duplicated block id: 451 size: 6 cleaned lines of code in 6 files: - clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java (52:59) - clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsResponse.java (61:68) - clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java (54:61) - clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java (48:55) - clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java (53:60) - clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java (112:119) duplicated block id: 452 size: 6 cleaned lines of code in 6 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java (106:113) - tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java (76:83) - tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java (93:100) - tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java (77:84) - tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionWorker.java (90:97) - tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java (131:138) duplicated block id: 453 size: 6 cleaned lines of code in 5 files: - core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala (484:489) - core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala (100:105) - core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala (94:99) - core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala (84:89) - core/src/main/scala/kafka/controller/ControllerChannelManager.scala (158:163) duplicated block id: 454 size: 6 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java (114:121) - clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java (80:87) - clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java (71:78) - clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java (126:133) duplicated block id: 455 size: 6 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java (54:61) - clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java (250:257) - clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java (62:69) - clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java (61:68) duplicated block id: 456 size: 6 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java (138:145) - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java (166:173) - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java (177:184) - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java (188:195) duplicated block id: 457 size: 6 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (241:246) - streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java (39:44) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java (123:128) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (228:233) duplicated block id: 458 size: 6 cleaned lines of code in 4 files: - connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkTask.java (76:82) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java (108:114) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkTask.java (93:99) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java (133:139) duplicated block id: 459 size: 6 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (504:511) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (737:744) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (869:876) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (932:939) duplicated block id: 460 size: 6 cleaned lines of code in 4 files: - clients/src/main/java/org/apache/kafka/common/requests/StopReplicaResponse.java (69:76) - clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java (70:77) - clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java (58:65) - clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java (69:76) duplicated block id: 461 size: 6 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (251:256) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java (183:188) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (176:181) - streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java (117:122) duplicated block id: 462 size: 6 cleaned lines of code in 4 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java (228:237) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java (76:85) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java (81:90) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java (85:94) duplicated block id: 463 size: 6 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java (165:170) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java (182:187) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java (199:204) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java (346:351) duplicated block id: 464 size: 6 cleaned lines of code in 4 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java (69:74) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java (86:91) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java (85:90) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java (80:85) duplicated block id: 465 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (245:250) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (331:336) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (426:431) duplicated block id: 466 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java (128:133) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java (188:193) - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java (183:188) duplicated block id: 467 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java (338:343) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java (288:293) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (497:502) duplicated block id: 468 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (614:619) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (646:651) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (678:683) duplicated block id: 469 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (303:308) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (369:374) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (1176:1181) duplicated block id: 470 size: 6 cleaned lines of code in 3 files: - core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala (78:83) - core/src/main/scala/kafka/controller/ControllerChannelManager.scala (142:147) - core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala (68:73) duplicated block id: 471 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java (77:85) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (104:111) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java (72:80) duplicated block id: 472 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java (164:172) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java (159:167) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java (155:163) duplicated block id: 473 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (164:169) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (193:198) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (432:437) duplicated block id: 474 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java (89:96) - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java (157:164) - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java (192:199) duplicated block id: 475 size: 6 cleaned lines of code in 3 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java (100:105) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java (117:122) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java (274:279) duplicated block id: 476 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (245:250) - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java (84:89) - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java (152:157) duplicated block id: 477 size: 6 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (1082:1090) - clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java (381:389) - clients/src/main/java/org/apache/kafka/common/protocol/Errors.java (467:475) duplicated block id: 478 size: 6 cleaned lines of code in 3 files: - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java (107:113) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java (53:59) - streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java (126:132) duplicated block id: 479 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java (29:34) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseRepartitionNode.java (38:43) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java (31:36) duplicated block id: 480 size: 6 cleaned lines of code in 3 files: - core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala (468:473) - core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala (84:89) - core/src/main/scala/kafka/server/KafkaServer.scala (524:529) duplicated block id: 481 size: 6 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java (40:49) - clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java (247:256) - clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java (58:67) duplicated block id: 482 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java (63:68) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java (88:93) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java (68:73) duplicated block id: 483 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java (98:104) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java (55:61) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java (79:85) duplicated block id: 484 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java (227:232) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java (244:249) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java (253:258) duplicated block id: 485 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java (117:125) - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java (282:290) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java (91:99) duplicated block id: 486 size: 6 cleaned lines of code in 3 files: - connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatConnector.java (71:78) - connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java (179:186) - connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java (114:121) duplicated block id: 487 size: 6 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/common/security/auth/SaslAuthenticationContext.java (45:52) - clients/src/main/java/org/apache/kafka/common/security/auth/SslAuthenticationContext.java (42:49) - clients/src/main/java/org/apache/kafka/common/security/auth/PlaintextAuthenticationContext.java (35:42) duplicated block id: 488 size: 6 cleaned lines of code in 3 files: - clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java (101:116) - clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java (200:207) - clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java (260:275) duplicated block id: 489 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java (234:240) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java (80:85) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (93:98) duplicated block id: 490 size: 6 cleaned lines of code in 3 files: - tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java (285:290) - tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java (220:225) - tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java (302:307) duplicated block id: 491 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (113:119) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (132:138) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (107:113) duplicated block id: 492 size: 6 cleaned lines of code in 3 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (177:184) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (242:249) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (252:261) duplicated block id: 493 size: 6 cleaned lines of code in 3 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigValueInfo.java (88:93) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigInfos.java (86:91) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigKeyInfo.java (142:147) duplicated block id: 494 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/controller/PartitionStateMachine.scala (371:376) - core/src/main/scala/kafka/controller/ReplicaStateMachine.scala (386:391) duplicated block id: 495 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java (94:101) - tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java (92:99) duplicated block id: 496 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegments.java (51:59) - streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegments.java (51:59) duplicated block id: 497 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java (229:234) - examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java (178:183) duplicated block id: 498 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsForLeaderEpochClient.java (97:102) - clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java (1062:1067) duplicated block id: 499 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/server/AdminManager.scala (490:496) - core/src/main/scala/kafka/server/AdminManager.scala (616:622) duplicated block id: 500 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (354:362) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (549:558) duplicated block id: 501 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/ClientRequest.java (55:60) - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (1217:1222) duplicated block id: 502 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersResult.java (60:65) - clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersResult.java (94:99) duplicated block id: 503 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java (217:224) - streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java (161:168) duplicated block id: 504 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala (303:308) - core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala (328:333) duplicated block id: 505 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServer.java (254:262) - clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java (236:244) duplicated block id: 506 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java (77:82) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java (52:57) duplicated block id: 507 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/server/AdminManager.scala (1196:1202) - core/src/main/scala/kafka/server/AdminManager.scala (1208:1214) duplicated block id: 508 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java (82:89) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java (68:75) duplicated block id: 509 size: 6 cleaned lines of code in 2 files: - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/consumer/SubscriptionStateBenchmark.java (45:50) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/AclAuthorizerBenchmark.java (65:70) duplicated block id: 510 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java (347:352) - streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java (355:360) duplicated block id: 511 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala (349:354) - core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala (376:381) duplicated block id: 512 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java (219:226) - clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java (235:242) duplicated block id: 513 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java (449:455) - streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java (527:533) duplicated block id: 514 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala (394:399) - core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala (413:418) duplicated block id: 515 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java (366:374) - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java (78:86) duplicated block id: 516 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java (30:35) - streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java (134:139) duplicated block id: 517 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/config/provider/FileConfigProvider.java (58:65) - clients/src/main/java/org/apache/kafka/common/config/provider/FileConfigProvider.java (85:92) duplicated block id: 518 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java (399:404) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (503:508) duplicated block id: 519 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (247:252) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (287:292) duplicated block id: 520 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java (110:117) - clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java (161:168) duplicated block id: 521 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala (1064:1069) - core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala (1076:1081) duplicated block id: 522 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java (359:364) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java (309:314) duplicated block id: 523 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/Cluster.java (83:88) - clients/src/main/java/org/apache/kafka/common/Cluster.java (94:99) duplicated block id: 524 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java (96:103) - clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsResponse.java (58:65) duplicated block id: 525 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java (157:162) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (475:480) duplicated block id: 526 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (299:304) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java (453:459) duplicated block id: 527 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java (49:54) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java (57:62) duplicated block id: 528 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java (101:113) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java (110:123) duplicated block id: 529 size: 6 cleaned lines of code in 2 files: - connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java (318:325) - connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverter.java (70:77) duplicated block id: 530 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/server/ClientQuotaManager.scala (146:153) - core/src/main/scala/kafka/utils/QuotaUtils.scala (62:72) duplicated block id: 531 size: 6 cleaned lines of code in 2 files: - connect/api/src/main/java/org/apache/kafka/connect/data/Values.java (467:473) - connect/api/src/main/java/org/apache/kafka/connect/data/Values.java (492:498) duplicated block id: 532 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (263:271) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (446:453) duplicated block id: 533 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java (253:258) - clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java (206:211) duplicated block id: 534 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java (483:492) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java (534:540) duplicated block id: 535 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (1216:1221) - clients/src/main/java/org/apache/kafka/clients/KafkaClient.java (196:201) duplicated block id: 536 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/Stores.java (125:132) - streams/src/main/java/org/apache/kafka/streams/state/Stores.java (159:166) duplicated block id: 537 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java (61:66) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java (72:77) duplicated block id: 538 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (194:202) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (255:263) duplicated block id: 539 size: 6 cleaned lines of code in 2 files: - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java (166:175) - jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java (179:189) duplicated block id: 540 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java (130:135) - connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java (142:147) duplicated block id: 541 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeResponse.java (49:58) - clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java (49:58) duplicated block id: 542 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java (204:209) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java (211:216) duplicated block id: 543 size: 6 cleaned lines of code in 2 files: - connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Checkpoint.java (74:83) - connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSync.java (52:61) duplicated block id: 544 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java (528:536) - tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java (662:669) duplicated block id: 545 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionSpec.java (128:135) - tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java (113:120) duplicated block id: 546 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java (651:656) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java (717:722) duplicated block id: 547 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (449:454) - streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java (746:751) duplicated block id: 548 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java (309:314) - tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java (341:346) duplicated block id: 549 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMap.java (30:39) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMapValues.java (29:38) duplicated block id: 550 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java (113:119) - streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java (112:118) duplicated block id: 551 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java (59:65) - clients/src/main/java/org/apache/kafka/common/utils/Crc32.java (98:104) duplicated block id: 552 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (889:897) - clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java (952:960) duplicated block id: 553 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/fault/FilesUnreadableFaultSpec.java (63:70) - tools/src/main/java/org/apache/kafka/trogdor/fault/Kibosh.java (77:84) duplicated block id: 554 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClient.java (79:86) - clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java (86:93) duplicated block id: 555 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java (199:216) - tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java (152:169) duplicated block id: 556 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java (53:60) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java (114:121) duplicated block id: 557 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java (94:109) - clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java (79:88) duplicated block id: 558 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java (155:160) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (162:167) duplicated block id: 559 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java (39:44) - streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java (100:105) duplicated block id: 560 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java (320:327) - tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java (275:282) duplicated block id: 561 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java (58:64) - streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java (89:94) duplicated block id: 562 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java (116:121) - clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java (116:121) duplicated block id: 563 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (110:117) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java (216:223) duplicated block id: 564 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java (80:89) - connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java (254:264) duplicated block id: 565 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (117:122) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java (141:146) duplicated block id: 566 size: 6 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java (303:308) - generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java (928:933) duplicated block id: 567 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java (174:181) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java (169:176) duplicated block id: 568 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/server/KafkaApis.scala (2770:2777) - core/src/main/scala/kafka/server/KafkaApis.scala (2797:2804) duplicated block id: 569 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java (207:212) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java (116:121) duplicated block id: 570 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (1072:1078) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (1100:1106) duplicated block id: 571 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java (606:613) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java (644:651) duplicated block id: 572 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java (223:230) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java (48:55) duplicated block id: 573 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/tools/ConsumerPerformance.scala (158:163) - core/src/main/scala/kafka/tools/ConsumerPerformance.scala (172:177) duplicated block id: 574 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java (108:116) - clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java (57:66) duplicated block id: 575 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteResponse.java (62:69) - clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsResponse.java (46:53) duplicated block id: 576 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (110:117) - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java (51:58) duplicated block id: 577 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java (306:315) - tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java (324:333) duplicated block id: 578 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (95:102) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (120:127) duplicated block id: 579 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala (233:238) - connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java (635:640) duplicated block id: 580 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorInfo.java (42:52) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorStateInfo.java (40:49) duplicated block id: 581 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (386:391) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java (403:408) duplicated block id: 582 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java (51:58) - clients/src/main/java/org/apache/kafka/common/utils/Crc32.java (87:94) duplicated block id: 583 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java (213:220) - streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java (207:214) duplicated block id: 584 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (1634:1645) - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (2555:2566) duplicated block id: 585 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/metrics/stats/Avg.java (32:39) - clients/src/main/java/org/apache/kafka/common/metrics/stats/WindowedSum.java (35:42) duplicated block id: 586 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java (147:153) - clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java (171:177) duplicated block id: 587 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java (176:183) - connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java (474:481) duplicated block id: 588 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java (92:98) - clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java (118:124) duplicated block id: 589 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/MetricName.java (102:107) - clients/src/main/java/org/apache/kafka/common/TopicPartition.java (45:50) duplicated block id: 590 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (2098:2107) - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (2164:2173) duplicated block id: 591 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java (116:121) - tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java (62:67) duplicated block id: 592 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (408:413) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (433:438) duplicated block id: 593 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (498:503) - streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java (554:559) duplicated block id: 594 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (176:181) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java (264:269) duplicated block id: 595 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java (56:61) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java (73:78) duplicated block id: 596 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersResult.java (57:62) - clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersResult.java (93:98) duplicated block id: 597 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java (346:351) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java (443:448) duplicated block id: 598 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java (290:298) - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java (51:59) duplicated block id: 599 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegments.java (31:38) - streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegments.java (31:38) duplicated block id: 600 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java (80:89) - streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java (67:76) duplicated block id: 601 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java (414:420) - clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java (431:437) duplicated block id: 602 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java (156:171) - clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java (194:209) duplicated block id: 603 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinedInternal.java (28:37) - streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java (213:222) duplicated block id: 604 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala (492:497) - core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala (500:505) duplicated block id: 605 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java (1391:1400) - clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java (1616:1625) duplicated block id: 606 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java (95:102) - connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java (83:90) duplicated block id: 607 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/tools/ConsoleConsumer.scala (380:385) - core/src/main/scala/kafka/tools/ConsoleProducer.scala (254:259) duplicated block id: 608 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java (215:220) - tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java (183:188) duplicated block id: 609 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (329:334) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (341:346) duplicated block id: 610 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java (498:510) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java (544:556) duplicated block id: 611 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (3421:3431) - clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java (3902:3912) duplicated block id: 612 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (164:171) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java (195:202) duplicated block id: 613 size: 6 cleaned lines of code in 2 files: - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java (87:96) - connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java (160:169) duplicated block id: 614 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java (69:74) - streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java (89:94) duplicated block id: 615 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/tools/StreamsResetter.java (497:505) - core/src/main/scala/kafka/tools/StreamsResetter.java (512:520) duplicated block id: 616 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/log/LogValidator.scala (89:94) - core/src/main/scala/kafka/log/LogValidator.scala (351:356) duplicated block id: 617 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/tools/GetOffsetShell.scala (35:40) - core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala (78:83) duplicated block id: 618 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (261:266) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java (1271:1276) duplicated block id: 619 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (144:149) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (173:178) duplicated block id: 620 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/log/LogManager.scala (515:522) - core/src/main/scala/kafka/log/LogManager.scala (552:559) duplicated block id: 621 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java (55:64) - streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java (46:56) duplicated block id: 622 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerState.java (49:56) - tools/src/main/java/org/apache/kafka/trogdor/rest/CreateWorkerRequest.java (46:53) duplicated block id: 623 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/server/ReplicaFetcherThread.scala (50:55) - core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala (47:52) duplicated block id: 624 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/converters/ByteArrayConverter.java (39:48) - connect/api/src/main/java/org/apache/kafka/connect/storage/SimpleHeaderConverter.java (44:54) duplicated block id: 625 size: 6 cleaned lines of code in 2 files: - generator/src/main/java/org/apache/kafka/message/FieldType.java (34:41) - generator/src/main/java/org/apache/kafka/message/FieldType.java (54:61) duplicated block id: 626 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java (148:153) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java (155:160) duplicated block id: 627 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala (744:749) - core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala (772:777) duplicated block id: 628 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java (186:192) - streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java (536:541) duplicated block id: 629 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java (264:271) - streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java (254:261) duplicated block id: 630 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndTimestamp.java (76:83) - clients/src/main/java/org/apache/kafka/common/record/FileRecords.java (523:530) duplicated block id: 631 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java (214:220) - streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java (256:262) duplicated block id: 632 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala (752:757) - core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala (780:785) duplicated block id: 633 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java (86:92) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/EagerAssignor.java (52:57) duplicated block id: 634 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java (65:80) - clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java (73:88) duplicated block id: 635 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java (539:544) - streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java (580:585) duplicated block id: 636 size: 6 cleaned lines of code in 2 files: - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java (64:69) - connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java (275:280) duplicated block id: 637 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java (224:230) - clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java (247:253) duplicated block id: 638 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java (292:297) - tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java (227:232) duplicated block id: 639 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/config/provider/FileConfigProvider.java (48:54) - clients/src/main/java/org/apache/kafka/common/config/provider/FileConfigProvider.java (77:83) duplicated block id: 640 size: 6 cleaned lines of code in 2 files: - core/src/main/scala/kafka/log/LogManager.scala (264:269) - core/src/main/scala/kafka/log/LogManager.scala (803:808) duplicated block id: 641 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosRule.java (79:84) - clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java (191:196) duplicated block id: 642 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java (452:459) - streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java (311:318) duplicated block id: 643 size: 6 cleaned lines of code in 2 files: - clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientCallbackHandler.java (71:77) - clients/src/main/java/org/apache/kafka/common/security/authenticator/AbstractLogin.java (98:103) duplicated block id: 644 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java (53:62) - streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransformValues.java (53:62) duplicated block id: 645 size: 6 cleaned lines of code in 2 files: - tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerDone.java (67:76) - tools/src/main/java/org/apache/kafka/trogdor/rest/TaskDone.java (63:72) duplicated block id: 646 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (118:123) - streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java (148:153) duplicated block id: 647 size: 6 cleaned lines of code in 2 files: - streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java (42:49) - streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java (91:98)