duplicated block id: 1 size: 74 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (64:143) - uforwarder-core/src/main/resources/workerJobs.html (65:144) duplicated block id: 2 size: 61 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (221:295) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (379:453) duplicated block id: 3 size: 43 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masters.html (37:89) - uforwarder-core/src/main/resources/workers.html (45:97) duplicated block id: 4 size: 42 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (111:162) - uforwarder-core/src/main/resources/workers.html (45:96) duplicated block id: 5 size: 42 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (111:162) - uforwarder-core/src/main/resources/masters.html (37:88) duplicated block id: 6 size: 40 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (1:44) - uforwarder-core/src/main/resources/workerJobs.html (1:44) duplicated block id: 7 size: 34 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (181:218) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (340:377) duplicated block id: 8 size: 32 cleaned lines of code in 2 files: - uforwarder/src/main/resources/application-uforwarder-controller.yaml (135:219) - uforwarder/src/main/resources/application-uforwarder-worker.yaml (39:123) duplicated block id: 9 size: 32 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (1:36) - uforwarder-core/src/main/resources/workerJobs.html (1:36) duplicated block id: 10 size: 32 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (1:36) - uforwarder-core/src/main/resources/workerJobStatus.html (1:36) duplicated block id: 11 size: 31 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (128:158) - uforwarder-core/src/main/resources/workerJobStatus.html (162:192) duplicated block id: 12 size: 30 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (167:196) - uforwarder-core/src/main/resources/masterJobs.html (200:229) duplicated block id: 13 size: 28 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masters.html (37:69) - uforwarder-core/src/main/resources/workerJobs.html (112:144) duplicated block id: 14 size: 28 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobs.html (112:144) - uforwarder-core/src/main/resources/workers.html (45:77) duplicated block id: 15 size: 27 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobs.html (167:193) - uforwarder-core/src/main/resources/workerJobs.html (197:223) duplicated block id: 16 size: 25 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (174:200) - uforwarder-core/src/main/resources/workerJobs.html (171:197) duplicated block id: 17 size: 25 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masters.html (1:29) - uforwarder-core/src/main/resources/workers.html (1:29) duplicated block id: 18 size: 23 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (207:229) - uforwarder-core/src/main/resources/workerJobs.html (171:193) duplicated block id: 19 size: 23 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (174:196) - uforwarder-core/src/main/resources/workerJobs.html (201:223) duplicated block id: 20 size: 23 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (207:229) - uforwarder-core/src/main/resources/workerJobs.html (201:223) duplicated block id: 21 size: 20 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (158:181) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (163:186) duplicated block id: 22 size: 18 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (107:129) - uforwarder-core/src/main/resources/workerJobs.html (146:168) duplicated block id: 23 size: 18 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java (27:44) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (50:67) duplicated block id: 24 size: 17 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (133:151) - uforwarder-core/src/main/resources/workerJobStatus.html (95:113) duplicated block id: 25 size: 17 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (95:113) - uforwarder-core/src/main/resources/workers.html (67:85) duplicated block id: 26 size: 17 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masters.html (59:77) - uforwarder-core/src/main/resources/workerJobStatus.html (95:113) duplicated block id: 27 size: 15 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (288:302) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (320:334) duplicated block id: 28 size: 15 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (204:218) - uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java (45:59) duplicated block id: 29 size: 15 cleaned lines of code in 2 files: - uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java (45:59) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (363:377) duplicated block id: 30 size: 15 cleaned lines of code in 2 files: - idl/src/main/proto/data/kafka/data-transfer/job.proto (119:135) - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (126:142) duplicated block id: 31 size: 14 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (36:49) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (40:53) duplicated block id: 32 size: 13 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (78:93) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (92:107) duplicated block id: 33 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobs.html (21:36) - uforwarder-core/src/main/resources/workers.html (14:29) duplicated block id: 34 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobs.html (1:14) - uforwarder-core/src/main/resources/workers.html (1:14) duplicated block id: 35 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (21:36) - uforwarder-core/src/main/resources/masters.html (14:29) duplicated block id: 36 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (1:14) - uforwarder-core/src/main/resources/workers.html (1:14) duplicated block id: 37 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (21:36) - uforwarder-core/src/main/resources/workers.html (14:29) duplicated block id: 38 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (1:14) - uforwarder-core/src/main/resources/masters.html (1:14) duplicated block id: 39 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (1:14) - uforwarder-core/src/main/resources/workers.html (1:14) duplicated block id: 40 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masters.html (14:29) - uforwarder-core/src/main/resources/workerJobStatus.html (21:36) duplicated block id: 41 size: 13 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java (185:197) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java (244:256) duplicated block id: 42 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masters.html (1:14) - uforwarder-core/src/main/resources/workerJobs.html (1:14) duplicated block id: 43 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masters.html (1:14) - uforwarder-core/src/main/resources/workerJobStatus.html (1:14) duplicated block id: 44 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masters.html (14:29) - uforwarder-core/src/main/resources/workerJobs.html (21:36) duplicated block id: 45 size: 13 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (101:113) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (58:70) duplicated block id: 46 size: 13 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (21:36) - uforwarder-core/src/main/resources/workers.html (14:29) duplicated block id: 47 size: 12 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (268:280) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (363:375) duplicated block id: 48 size: 12 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java (286:297) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java (313:324) duplicated block id: 49 size: 12 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (316:328) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (418:430) duplicated block id: 50 size: 12 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (88:122) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (90:128) duplicated block id: 51 size: 12 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (51:62) - uforwarder-core/src/main/resources/workerJobs.html (48:59) duplicated block id: 52 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (208:218) - uforwarder-core/src/main/resources/workerJobStatus.html (139:149) duplicated block id: 53 size: 11 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java (203:213) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java (171:181) duplicated block id: 54 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (139:149) - uforwarder-core/src/main/resources/workerJobs.html (172:182) duplicated block id: 55 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (139:149) - uforwarder-core/src/main/resources/workerJobs.html (202:212) duplicated block id: 56 size: 11 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (100:110) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (172:182) duplicated block id: 57 size: 11 cleaned lines of code in 2 files: - idl/src/main/proto/data/kafka/data-transfer/job.proto (102:114) - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (109:121) duplicated block id: 58 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (173:183) - uforwarder-core/src/main/resources/workerJobs.html (172:182) duplicated block id: 59 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (175:185) - uforwarder-core/src/main/resources/workerJobStatus.html (173:183) duplicated block id: 60 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (173:183) - uforwarder-core/src/main/resources/workerJobs.html (202:212) duplicated block id: 61 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (175:185) - uforwarder-core/src/main/resources/workerJobStatus.html (139:149) duplicated block id: 62 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (221:231) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (266:276) duplicated block id: 63 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java (51:65) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (74:88) duplicated block id: 64 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (208:218) - uforwarder-core/src/main/resources/workerJobStatus.html (173:183) duplicated block id: 65 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (173:182) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (58:67) duplicated block id: 66 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (681:690) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (732:741) duplicated block id: 67 size: 10 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecord.java (43:52) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecord.java (59:68) duplicated block id: 68 size: 10 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (269:279) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (296:306) duplicated block id: 69 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (681:690) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (711:720) duplicated block id: 70 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (711:720) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (732:741) duplicated block id: 71 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (57:66) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (229:238) duplicated block id: 72 size: 10 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (221:230) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (250:259) duplicated block id: 73 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java (169:178) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java (128:137) duplicated block id: 74 size: 10 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManager.java (428:437) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java (39:48) duplicated block id: 75 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (125:134) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (138:147) duplicated block id: 76 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (42:51) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (62:72) duplicated block id: 77 size: 10 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (250:259) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (266:275) duplicated block id: 78 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (563:580) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (868:885) duplicated block id: 79 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java (290:299) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java (136:145) duplicated block id: 80 size: 10 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (142:155) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (149:161) duplicated block id: 81 size: 9 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateConnecting.java (28:36) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (58:66) duplicated block id: 82 size: 9 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java (132:144) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (338:350) duplicated block id: 83 size: 9 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (367:376) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (422:431) duplicated block id: 84 size: 9 cleaned lines of code in 2 files: - uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java (34:43) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (400:409) duplicated block id: 85 size: 9 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java (84:93) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (285:295) duplicated block id: 86 size: 9 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (41:49) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (74:82) duplicated block id: 87 size: 9 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (173:181) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (230:238) duplicated block id: 88 size: 9 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManager.java (429:437) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java (277:285) duplicated block id: 89 size: 9 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java (40:48) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java (277:285) duplicated block id: 90 size: 9 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (99:107) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (116:124) duplicated block id: 91 size: 9 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (95:105) - uforwarder-core/src/main/resources/workerJobs.html (134:144) duplicated block id: 92 size: 9 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (101:109) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (230:238) duplicated block id: 93 size: 9 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (400:408) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (422:430) duplicated block id: 94 size: 9 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateConnecting.java (28:36) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java (35:43) duplicated block id: 95 size: 9 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (242:251) - uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java (34:43) duplicated block id: 96 size: 8 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (163:170) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (179:186) duplicated block id: 97 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobStatus.html (38:45) - uforwarder-core/src/main/resources/workerJobs.html (38:45) duplicated block id: 98 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/BufferedWriteDecorator.java (99:110) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LoggingAndMetricsStoreDecorator.java (49:60) duplicated block id: 99 size: 8 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/StubManager.java (152:159) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java (174:181) duplicated block id: 100 size: 8 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (163:170) - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (174:181) duplicated block id: 101 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/StoreConfiguration.java (60:73) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/WorkerStoreConfiguration.java (79:92) duplicated block id: 102 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (136:143) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (66:73) duplicated block id: 103 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (126:133) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (147:154) duplicated block id: 104 size: 8 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (117:124) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (172:179) duplicated block id: 105 size: 8 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (168:175) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (179:186) duplicated block id: 106 size: 8 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (46:53) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (62:69) duplicated block id: 107 size: 8 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (320:328) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (367:375) duplicated block id: 108 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (128:135) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (141:148) duplicated block id: 109 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (160:167) - uforwarder-core/src/main/resources/workerJobs.html (160:167) duplicated block id: 110 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (35:42) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (55:62) duplicated block id: 111 size: 8 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (272:280) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (422:430) duplicated block id: 112 size: 8 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (272:280) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (320:328) duplicated block id: 113 size: 8 cleaned lines of code in 2 files: - idl/src/main/proto/data/kafka/data-transfer/job.proto (36:43) - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (42:50) duplicated block id: 114 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (44:51) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (65:72) duplicated block id: 115 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (160:167) - uforwarder-core/src/main/resources/workerJobStatus.html (121:128) duplicated block id: 116 size: 8 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java (206:213) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/StubManager.java (152:159) duplicated block id: 117 size: 8 cleaned lines of code in 2 files: - uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerBytesServerMethodDefinition.java (131:140) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java (226:235) duplicated block id: 118 size: 8 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java (255:262) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java (253:260) duplicated block id: 119 size: 8 cleaned lines of code in 2 files: - uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/Utils.java (45:52) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java (35:42) duplicated block id: 120 size: 8 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (957:964) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java (139:146) duplicated block id: 121 size: 8 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (174:181) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (168:175) duplicated block id: 122 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (135:142) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (24:31) duplicated block id: 123 size: 8 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (563:570) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (264:271) duplicated block id: 124 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (25:31) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (45:51) duplicated block id: 125 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (534:540) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java (291:297) duplicated block id: 126 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (25:31) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (66:72) duplicated block id: 127 size: 7 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (225:231) - uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java (64:70) duplicated block id: 128 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java (40:46) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcUtils.java (66:72) duplicated block id: 129 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (16:22) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (55:61) duplicated block id: 130 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (16:22) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (35:41) duplicated block id: 131 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java (160:168) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java (182:190) duplicated block id: 132 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/ControllerAutoConfiguration.java (47:53) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/ControllerAutoConfiguration.java (58:64) duplicated block id: 133 size: 7 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (57:63) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (148:154) duplicated block id: 134 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (136:142) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (45:51) duplicated block id: 135 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (166:172) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (210:216) duplicated block id: 136 size: 7 cleaned lines of code in 2 files: - uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java (95:101) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/MockConsumerServiceStarter.java (53:61) duplicated block id: 137 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (166:172) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (191:197) duplicated block id: 138 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java (277:283) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcUtils.java (66:72) duplicated block id: 139 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (463:470) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (485:492) duplicated block id: 140 size: 7 cleaned lines of code in 2 files: - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (1:11) - idl/src/main/proto/data/kafka/data-transfer/job_status.proto (1:11) duplicated block id: 141 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateConnecting.java (50:58) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java (59:67) duplicated block id: 142 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (189:195) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (209:215) duplicated block id: 143 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java (156:165) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java (182:191) duplicated block id: 144 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManager.java (429:435) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcUtils.java (66:72) duplicated block id: 145 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (100:106) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (142:148) duplicated block id: 146 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (289:295) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (373:379) duplicated block id: 147 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (205:211) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java (318:324) duplicated block id: 148 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workerJobs.html (146:152) - uforwarder-core/src/main/resources/workers.html (79:85) duplicated block id: 149 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (118:124) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (58:64) duplicated block id: 150 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masters.html (71:77) - uforwarder-core/src/main/resources/workerJobs.html (146:152) duplicated block id: 151 size: 7 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (588:594) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (292:298) duplicated block id: 152 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (205:211) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (534:540) duplicated block id: 153 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (145:151) - uforwarder-core/src/main/resources/workerJobs.html (146:152) duplicated block id: 154 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (51:70) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (54:73) duplicated block id: 155 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/IdExtractor.java (23:31) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalSequencer.java (30:38) duplicated block id: 156 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/BufferedWriteDecorator.java (109:119) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TTLDecorator.java (151:161) duplicated block id: 157 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (555:561) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (859:865) duplicated block id: 158 size: 7 cleaned lines of code in 2 files: - uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java (64:70) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (383:389) duplicated block id: 159 size: 7 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (251:257) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (259:265) duplicated block id: 160 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (518:524) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (1157:1163) duplicated block id: 161 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (461:467) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (481:487) duplicated block id: 162 size: 7 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (251:257) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (267:273) duplicated block id: 163 size: 7 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (259:265) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (267:273) duplicated block id: 164 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java (293:299) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (957:963) duplicated block id: 165 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java (92:98) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/StreamingJobCreator.java (29:35) duplicated block id: 166 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (118:124) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (230:236) duplicated block id: 167 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/JobGroupIdProvider.java (16:24) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalStore.java (98:106) duplicated block id: 168 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/IdExtractor.java (23:31) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/JobGroupIdProvider.java (16:24) duplicated block id: 169 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalSequencer.java (30:38) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalStore.java (98:106) duplicated block id: 170 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (205:211) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java (291:297) duplicated block id: 171 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (191:197) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (210:216) duplicated block id: 172 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (211:217) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (951:957) duplicated block id: 173 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (94:123) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (78:107) duplicated block id: 174 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java (87:93) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (373:379) duplicated block id: 175 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/JobGroupIdProvider.java (16:24) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalSequencer.java (30:38) duplicated block id: 176 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java (218:229) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java (287:298) duplicated block id: 177 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/workers.html (101:107) - uforwarder-core/src/main/resources/workers.html (111:117) duplicated block id: 178 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/IdExtractor.java (23:31) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalStore.java (98:106) duplicated block id: 179 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (140:146) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (153:159) duplicated block id: 180 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (534:540) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java (318:324) duplicated block id: 181 size: 7 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (203:209) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (211:217) duplicated block id: 182 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/resources/masterJobs.html (38:44) - uforwarder-core/src/main/resources/workerJobStatus.html (38:44) duplicated block id: 183 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (77:83) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateConnecting.java (21:27) duplicated block id: 184 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 185 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 186 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (77:82) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (50:55) duplicated block id: 187 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (166:171) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (142:147) duplicated block id: 188 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (128:133) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (154:159) duplicated block id: 189 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (475:480) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (483:488) duplicated block id: 190 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/resources/application-uforwarder-controller.yaml (21:31) - uforwarder/src/main/resources/application-uforwarder-worker.yaml (19:29) duplicated block id: 191 size: 6 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (335:340) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java (51:56) duplicated block id: 192 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30) duplicated block id: 193 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (88:93) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (65:70) duplicated block id: 194 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaCheckpointManager.java (60:65) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaCheckpointManager.java (69:74) duplicated block id: 195 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (191:196) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (100:105) duplicated block id: 196 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207) duplicated block id: 197 size: 6 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (96:101) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (120:125) duplicated block id: 198 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247) duplicated block id: 199 size: 6 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (218:223) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (271:276) duplicated block id: 200 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247) duplicated block id: 201 size: 6 cleaned lines of code in 2 files: - idl/src/main/proto/data/kafka/data-transfer/job.proto (264:269) - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (192:197) duplicated block id: 202 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247) duplicated block id: 203 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (191:196) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (142:147) duplicated block id: 204 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java (87:92) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java (96:101) duplicated block id: 205 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaCheckpointManager.java (71:76) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaCheckpointManager.java (81:86) duplicated block id: 206 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (442:447) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (498:503) duplicated block id: 207 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247) duplicated block id: 208 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (166:171) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (100:105) duplicated block id: 209 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 210 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (77:82) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java (27:32) duplicated block id: 211 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207) duplicated block id: 212 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28) duplicated block id: 213 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (111:116) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (154:159) duplicated block id: 214 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (210:215) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (100:105) duplicated block id: 215 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207) duplicated block id: 216 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (111:116) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (141:146) duplicated block id: 217 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143) duplicated block id: 218 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (210:215) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (142:147) duplicated block id: 219 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (111:116) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java (128:133) duplicated block id: 220 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247) duplicated block id: 221 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (98:103) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (166:171) duplicated block id: 222 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28) duplicated block id: 223 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54) duplicated block id: 224 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (102:107) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (121:126) duplicated block id: 225 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 226 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (65:70) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (90:95) duplicated block id: 227 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54) duplicated block id: 228 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (98:103) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (191:196) duplicated block id: 229 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207) duplicated block id: 230 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (98:103) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (142:147) duplicated block id: 231 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (166:171) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (229:234) duplicated block id: 232 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (990:997) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (1003:1008) duplicated block id: 233 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (88:93) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (68:73) duplicated block id: 234 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (98:103) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (210:215) duplicated block id: 235 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30) duplicated block id: 236 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28) duplicated block id: 237 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (98:103) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (100:105) duplicated block id: 238 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateConnecting.java (21:26) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (50:55) duplicated block id: 239 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (78:106) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (100:128) duplicated block id: 240 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 241 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (98:103) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (229:234) duplicated block id: 242 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (98:103) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (139:144) duplicated block id: 243 size: 6 cleaned lines of code in 2 files: - uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/Utils.java (47:52) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (324:329) duplicated block id: 244 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java (95:101) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/WorkerManager.java (47:53) duplicated block id: 245 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143) duplicated block id: 246 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java (166:171) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java (252:257) duplicated block id: 247 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56) duplicated block id: 248 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (146:151) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (210:215) duplicated block id: 249 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java (67:72) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java (49:54) duplicated block id: 250 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java (173:178) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/StubManager.java (170:175) duplicated block id: 251 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (229:234) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (142:147) duplicated block id: 252 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28) duplicated block id: 253 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateConnecting.java (21:26) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java (27:32) duplicated block id: 254 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (167:172) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (176:181) duplicated block id: 255 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (139:144) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (142:147) duplicated block id: 256 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator/LeaderSelector.java (125:134) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/ZKSequencer.java (48:56) duplicated block id: 257 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (229:234) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (100:105) duplicated block id: 258 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateConnecting.java (41:46) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java (49:54) duplicated block id: 259 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28) duplicated block id: 260 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (139:144) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (100:105) duplicated block id: 261 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java (104:109) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java (149:154) duplicated block id: 262 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143) duplicated block id: 263 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (210:215) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (229:234) duplicated block id: 264 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java (166:176) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java (145:154) duplicated block id: 265 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54) duplicated block id: 266 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (516:521) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (525:530) duplicated block id: 267 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (68:73) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (90:95) duplicated block id: 268 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java (67:72) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java (84:89) duplicated block id: 269 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 270 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78) duplicated block id: 271 size: 6 cleaned lines of code in 2 files: - idl/src/main/proto/data/kafka/data-transfer/job.proto (19:24) - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (21:26) duplicated block id: 272 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/StubManager.java (170:175) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java (132:137) duplicated block id: 273 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 274 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54) duplicated block id: 275 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (308:318) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (824:832) duplicated block id: 276 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54) duplicated block id: 277 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54) duplicated block id: 278 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (139:144) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (229:234) duplicated block id: 279 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247) duplicated block id: 280 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalar.java (140:145) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalar.java (159:164) duplicated block id: 281 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30) duplicated block id: 282 size: 6 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (527:532) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Utils.java (14:19) duplicated block id: 283 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (139:144) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (210:215) duplicated block id: 284 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (455:460) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (477:482) duplicated block id: 285 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 286 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (139:144) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (191:196) duplicated block id: 287 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 288 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28) duplicated block id: 289 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java (84:89) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java (49:54) duplicated block id: 290 size: 6 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (218:223) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (298:303) duplicated block id: 291 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56) duplicated block id: 292 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (139:144) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (166:171) duplicated block id: 293 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (118:123) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (121:126) duplicated block id: 294 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30) duplicated block id: 295 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247) duplicated block id: 296 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (161:170) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (35:44) duplicated block id: 297 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (453:458) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (461:466) duplicated block id: 298 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LoggingAndMetricsStoreDecorator.java (46:55) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TTLDecorator.java (124:133) duplicated block id: 299 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28) duplicated block id: 300 size: 6 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (324:329) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java (37:42) duplicated block id: 301 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207) duplicated block id: 302 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java (214:222) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java (201:209) duplicated block id: 303 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (191:196) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java (229:234) duplicated block id: 304 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247) duplicated block id: 305 size: 6 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java (528:533) - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (267:272) duplicated block id: 306 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (244:249) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (313:318)