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 (388:462) duplicated block id: 3 size: 50 cleaned lines of code in 2 files: - instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java (73:122) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (121:170) duplicated block id: 4 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: 5 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: 6 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: 7 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: 8 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 (349:386) duplicated block id: 9 size: 32 cleaned lines of code in 2 files: - uforwarder/src/main/resources/application-uforwarder-controller.yaml (132:216) - uforwarder/src/main/resources/application-uforwarder-worker.yaml (46:130) duplicated block id: 10 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: 11 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: 12 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: 13 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: 14 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: 15 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: 16 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: 17 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: 18 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: 19 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: 20 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: 21 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: 22 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 (172:195) duplicated block id: 23 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: 24 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: 25 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: 26 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: 27 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: 28 size: 15 cleaned lines of code in 2 files: - idl/src/main/proto/data/kafka/data-transfer/job.proto (123:139) - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (130:146) duplicated block id: 29 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: 30 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 (372:386) duplicated block id: 31 size: 14 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (295:308) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (327:340) duplicated block id: 32 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: 33 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: 34 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: 35 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: 36 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: 37 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: 38 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: 39 size: 13 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (96:108) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (58:70) 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-core/src/main/resources/masters.html (1:14) - uforwarder-core/src/main/resources/workerJobs.html (1:14) 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/workerJobStatus.html (1:14) duplicated block id: 43 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: 44 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: 45 size: 13 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java (227:239) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java (287:299) duplicated block id: 46 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: 47 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: 48 size: 12 cleaned lines of code in 2 files: - uforwarder/src/main/resources/application-uforwarder-controller.yaml (21:39) - uforwarder/src/main/resources/application-uforwarder-worker.yaml (16:35) 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 (90:124) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (89:127) 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: - idl/src/main/proto/data/kafka/data-transfer/job.proto (106:118) - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (113:125) duplicated block id: 57 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: 58 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: 59 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: 60 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: 61 size: 11 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (376:386) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (393:403) 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/fetchers/kafka/KafkaDelayProcessManager.java (99:109) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaDelayProcessManager.java (150:160) duplicated block id: 64 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: 65 size: 11 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (95:105) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (167:177) duplicated block id: 66 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: 67 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (127:136) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (144:153) 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 (793:802) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (814:823) duplicated block id: 70 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: 71 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 (178:187) duplicated block id: 72 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (168:177) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (58:67) duplicated block id: 73 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: 74 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: 75 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (763:772) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (793:802) duplicated block id: 76 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (763:772) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (814:823) duplicated block id: 77 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: 78 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: 79 size: 10 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecord.java (47:56) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecord.java (63:72) 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 (158:170) duplicated block id: 81 size: 10 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (645:662) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (950:967) 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/StateConnecting.java (28:36) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java (58:66) duplicated block id: 83 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: 84 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: 85 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 (409:418) duplicated block id: 86 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: 87 size: 9 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (49:57) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (60:68) duplicated block id: 88 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: 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 (293:301) duplicated block id: 90 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 (293:301) duplicated block id: 91 size: 9 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (94:102) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (111:119) 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 (96:104) - 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 (511:519) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (533:541) duplicated block id: 94 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: 95 size: 9 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (168:176) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (230:238) duplicated block id: 96 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: 97 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: 98 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: 99 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (393:400) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (952:959) duplicated block id: 100 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: 101 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: 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 (376:383) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (1059:1066) duplicated block id: 103 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: 104 size: 8 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (112:119) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (167:174) duplicated block id: 105 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (478:485) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (1059:1066) duplicated block id: 106 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: 107 size: 8 cleaned lines of code in 2 files: - uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java (78:87) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (94:103) duplicated block id: 108 size: 8 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (177:184) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (188:195) duplicated block id: 109 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 (188:195) duplicated block id: 110 size: 8 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (190:197) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (211:218) duplicated block id: 111 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: 112 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: 113 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: 114 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (376:383) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (952:959) duplicated block id: 115 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 (177:184) duplicated block id: 116 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (393:400) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (1059:1066) duplicated block id: 117 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (376:383) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (478:485) duplicated block id: 118 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: 119 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: 120 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (478:485) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (952:959) duplicated block id: 121 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (952:959) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (1059:1066) duplicated block id: 122 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: 123 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: 124 size: 8 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (393:400) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (478:485) duplicated block id: 125 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 (242:251) duplicated block id: 126 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: 127 size: 8 cleaned lines of code in 2 files: - idl/src/main/proto/data/kafka/data-transfer/job.proto (37:44) - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (43:51) duplicated block id: 128 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: 129 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: 130 size: 8 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java (354:362) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java (394:403) duplicated block id: 131 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: 132 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: 133 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: 134 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: 135 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (41:47) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (47:53) duplicated block id: 136 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: 137 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (645:651) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java (318:324) duplicated block id: 138 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (96:125) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (80:109) duplicated block id: 139 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: 140 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java (219:230) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java (288:299) duplicated block id: 141 size: 7 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (212:218) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (220:226) duplicated block id: 142 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: 143 size: 7 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (268:274) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (276:282) duplicated block id: 144 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: 145 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (113:119) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (58:64) duplicated block id: 146 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: 147 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: 148 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 (645:651) duplicated block id: 149 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (637:643) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (941:947) duplicated block id: 150 size: 7 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (260:266) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (276:282) duplicated block id: 151 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: 152 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: 153 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: 154 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: 155 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: 156 size: 7 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (260:266) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (268:274) duplicated block id: 157 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: 158 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: 159 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: 160 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 (392:398) duplicated block id: 161 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: 162 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: 163 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (572:578) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (592:598) duplicated block id: 164 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: 165 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: 166 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: 167 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (565:571) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (1216:1222) 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/LocalSequencer.java (30:38) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalStore.java (98:106) duplicated block id: 169 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (345:351) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (379:385) duplicated block id: 170 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: 171 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (113:119) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (230:236) duplicated block id: 172 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: 173 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: 174 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: 175 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: 176 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java (293:299) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcUtils.java (66:72) duplicated block id: 177 size: 7 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (510:517) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (532:539) 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/KafkaDelayProcessManager.java (82:88) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaDelayProcessManager.java (103:109) duplicated block id: 181 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (345:351) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (396:402) duplicated block id: 182 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (645:651) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java (291:297) 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/ControllerAutoConfiguration.java (40:46) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/ControllerAutoConfiguration.java (51:57) duplicated block id: 184 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: 185 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: 186 size: 7 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaDelayProcessManager.java (82:88) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaDelayProcessManager.java (154:160) duplicated block id: 187 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: 188 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: 189 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: 190 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: 191 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: 192 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (120:125) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (126:131) 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/KafkaCheckpointManager.java (60:65) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaCheckpointManager.java (69:74) duplicated block id: 194 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: 195 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: 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/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 (244:250) duplicated block id: 198 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: 199 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 (244:250) duplicated block id: 200 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 (244:250) duplicated block id: 201 size: 6 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (333:338) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java (37:42) duplicated block id: 202 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: 203 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: 204 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (80:108) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (99:127) 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/ProcessorMessage.java (244:250) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 207 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (90:95) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (67:72) duplicated block id: 208 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 (244:250) duplicated block id: 209 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (355:365) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (906:914) duplicated block id: 210 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: 211 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: 212 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: 213 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (42:47) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (52:57) duplicated block id: 214 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: 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/processor/DispatcherResponseAndOffset.java (22:28) 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 (154:159) 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/grpc/GrpcRequest.java (201:207) 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 (100:105) 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 (141:146) duplicated block id: 220 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 (132:138) 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 (210:215) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (142:147) duplicated block id: 222 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: 223 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (563:568) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (572:577) duplicated block id: 224 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (132:138) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54) duplicated block id: 225 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: 226 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 (244:250) duplicated block id: 227 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: 228 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: 229 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: 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/ControllerAdminService.java (191:196) 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 (98:103) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java (142:147) duplicated block id: 232 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AdaptiveInflightLimiter.java (46:56) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiter.java (110:119) duplicated block id: 233 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: 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-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (66:71) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (60:65) 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 (67:72) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (89:94) duplicated block id: 240 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (66:71) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (49:54) duplicated block id: 241 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: 242 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (1056:1063) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (1069:1074) duplicated block id: 243 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (104:109) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (126:131) duplicated block id: 244 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: 245 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: 246 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 (333:338) duplicated block id: 247 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java (96:102) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/WorkerManager.java (47:53) duplicated block id: 248 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 (132:138) duplicated block id: 249 size: 6 cleaned lines of code in 2 files: - idl/src/main/proto/data/kafka/data-transfer/job.proto (20:25) - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (22:27) duplicated block id: 250 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: 251 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: 252 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: 253 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: 254 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: 255 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: 256 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: 257 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: 258 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (522:527) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (530:535) duplicated block id: 259 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: 260 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: 261 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: 262 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: 263 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: 264 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: 265 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 (340:345) duplicated block id: 266 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: 267 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 (132:138) duplicated block id: 268 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: 269 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: 270 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: 271 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (502:507) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (524:529) duplicated block id: 272 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: 273 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (132:138) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207) duplicated block id: 274 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: 275 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: 276 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: 277 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: 278 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (132:138) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22) duplicated block id: 279 size: 6 cleaned lines of code in 2 files: - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java (344:349) - uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java (51:56) duplicated block id: 280 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: 281 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (163:168) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (188:193) duplicated block id: 282 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: 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 (229:234) duplicated block id: 284 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 (244:250) duplicated block id: 285 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (1189:1196) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaDelayProcessManager.java (107:114) duplicated block id: 286 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: 287 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: 288 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: 289 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: 290 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (489:494) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (545:550) duplicated block id: 291 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: 292 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (132:138) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28) duplicated block id: 293 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (132:138) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30) duplicated block id: 294 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: 295 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: 296 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: 297 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: 298 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java (373:381) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java (410:424) duplicated block id: 299 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: 300 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: 301 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: 302 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: 303 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/utils/NodeConfigurationUtils.java (8:21) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/utils/NodeConfigurationUtils.java (8:21) duplicated block id: 304 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: 305 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: 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 (702:707) - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java (715:720) duplicated block id: 307 size: 6 cleaned lines of code in 2 files: - idl/src/main/proto/data/kafka/data-transfer/job.proto (286:291) - idl/src/main/proto/data/kafka/data-transfer/job_group.proto (198:203) duplicated block id: 308 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 (244:250) duplicated block id: 309 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: 310 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: 311 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (141:146) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (210:215) duplicated block id: 312 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: 313 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (132:138) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (244:250) duplicated block id: 314 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (73:78) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (89:94) duplicated block id: 315 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: 316 size: 6 cleaned lines of code in 2 files: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (90:95) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (73:78) duplicated block id: 317 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (500:505) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java (508:513) duplicated block id: 318 size: 6 cleaned lines of code in 2 files: - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (67:72) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (73:78)