12 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (88:122, 17%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (90:128, 9%) 10 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManager.java (428:437, 3%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java (39:48, 45%) 9 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManager.java (429:437, 2%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java (277:285, 3%) 7 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManager.java (429:435, 2%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcUtils.java (66:72, 13%) 7 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (94:123, 10%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (78:107, 11%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78, 16%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22, 22%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47, 22%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30, 21%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (88:93, 8%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (65:70, 9%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78, 16%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207, 3%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78, 16%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247, 2%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56, 26%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22, 22%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47, 22%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28, 27%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47, 22%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207, 3%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47, 22%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143, 4%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56, 26%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247, 2%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56, 26%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28, 27%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56, 26%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54, 24%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47, 22%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/TopicPartitionOffset.java (16:22, 22%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (88:93, 8%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (68:73, 8%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78, 16%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30, 21%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78, 16%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143, 4%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56, 26%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java (137:143, 4%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78, 16%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54, 24%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47, 22%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/ClusterAndIsSecureKey.java (48:54, 24%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/VersionedProto.java (41:47, 22%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java (241:247, 2%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56, 26%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30, 21%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (118:123, 8%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (121:126, 8%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobGroupKey.java (72:78, 16%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DispatcherResponseAndOffset.java (22:28, 27%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/ItemAndJob.java (50:56, 26%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java (201:207, 3%)