12 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (90:124, 16%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (89:127, 13%) 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 (293:301, 3%) 7 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (96:125, 9%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (80:109, 11%) 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%) 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, 20%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (120:125, 8%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (126:131, 7%) 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/worker/fetchers/kafka/KafkaFetcherThread.java (90:95, 8%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java (67:72, 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/processor/ProcessorMessage.java (244:250, 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 (132:138, 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 (244:250, 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/controller/autoscalar/JobGroupKey.java (72:78, 16%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java (24:30, 20%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (66:71, 8%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java (60:65, 6%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (66:71, 8%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (49:54, 7%) 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 (132:138, 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 (132:138, 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 (244:250, 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, 20%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/utils/NodeConfigurationUtils.java (8:21, 50%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/utils/NodeConfigurationUtils.java (8:21, 50%) 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%) 6 duplicated lines in: - uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java (90:95, 8%) - uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java (73:78, 7%)