from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredTags.java"
   contains "import com.uber.data.kafka.datatransfer.common.RoutingUtils;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java"
   contains "import com.uber.data.kafka.datatransfer.common.RoutingUtils;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/management/WorkerStubsJson.java"
   contains "import com.uber.data.kafka.datatransfer.worker.pipelines.Pipeline;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/KafkaAdminClientConfiguration.java"
   contains "import com.uber.data.kafka.datatransfer.common.KafkaClusterResolver;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherImpl.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcUtils.java"
   contains "import com.uber.data.kafka.datatransfer.common.RoutingUtils;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/DedupHeaderInterceptor.java"
   contains "import com.uber.data.kafka.datatransfer.common.StructuredTags;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java"
   contains "import static com.uber.data.kafka.datatransfer.common.MetadataUtils.metadataInterceptor;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcherFactory.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/OriginalClusterFilter.java"
   contains "import com.uber.data.kafka.datatransfer.worker.common.ItemAndJob;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/Filter.java"
   contains "import com.uber.data.kafka.datatransfer.worker.common.ItemAndJob;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/CompositeFilter.java"
   contains "import com.uber.data.kafka.datatransfer.worker.common.ItemAndJob;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java"
   contains "import com.uber.data.kafka.datatransfer.common.StructuredLogging;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherAutoConfiguration.java"
   contains "import com.uber.data.kafka.datatransfer.worker.fetchers.kafka.KafkaFetcherConfiguration;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java"
   contains "import com.uber.data.kafka.datatransfer.common.RoutingUtils;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactory.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckTrackingQueue.java"
   contains "import com.uber.data.kafka.datatransfer.worker.common.MetricSource;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/DlqDispatchManager.java"
   contains "import com.uber.data.kafka.datatransfer.worker.common.MetricSource;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/OutboundMessageLimiter.java"
   contains "import com.uber.data.kafka.datatransfer.worker.common.MetricSource;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckManager.java"
   contains "import com.uber.data.kafka.datatransfer.worker.common.MetricSource;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/UForwarder.java"
   contains "import com.uber.data.kafka.datatransfer.worker.DataTransferWorker;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java"
   contains "import com.uber.data.kafka.datatransfer.common.AdminClient;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/GrpcServerRunner.java"
   contains "import com.uber.data.kafka.datatransfer.controller.rpc.ControllerAdminService;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancer.java"
   contains "import com.uber.data.kafka.datatransfer.common.AdminClient;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java"
   contains "import com.uber.data.kafka.datatransfer.common.WorkerUtils;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancer.java"
   contains "import com.uber.data.kafka.datatransfer.common.WorkerUtils;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java"
   contains "import com.uber.data.kafka.datatransfer.common.WorkerUtils;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/StreamingRpcUriRebalancer.java"
   contains "import com.uber.data.kafka.datatransfer.controller.autoscalar.Scalar;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java"
   contains "import com.uber.data.kafka.datatransfer.controller.autoscalar.Scalar;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/ShadowRebalancerDelegateImpl.java"
   contains "import com.uber.data.kafka.datatransfer.controller.rebalancer.Rebalancer;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingJob.java"
   contains "import com.uber.data.kafka.datatransfer.controller.rebalancer.RebalancingJobGroup;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/JobGroupAndWorkerPodifier.java"
   contains "import com.uber.data.kafka.datatransfer.controller.rebalancer.JobPodPlacementProvider;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg/CoordinatorAutoConfiguration.java"
   contains "import com.uber.data.kafka.datatransfer.common.CoreInfra;"

from: uforwarder
to: uforwarder-core
evidence:
 - file: "uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java"
   contains "import com.uber.data.kafka.datatransfer.common.ZKStringSerializer;"

from: uforwarder
to: instrumentation
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/KafkaAdminClientConfiguration.java"
   contains "import com.uber.data.kafka.instrumentation.Instrumentation;"

from: uforwarder
to: instrumentation
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java"
   contains "import com.uber.data.kafka.instrumentation.Instrumentation;"

from: uforwarder
to: instrumentation
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java"
   contains "import com.uber.data.kafka.instrumentation.Tags;"

from: uforwarder
to: instrumentation
evidence:
 - file: "uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java"
   contains "import com.uber.data.kafka.instrumentation.DirectSupplier;"

from: uforwarder
to: uforwarder-client
evidence:
 - file: "uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java"
   contains "import com.uber.data.kafka.consumerproxy.client.grpc.ConsumerBytesServerMethodDefinition;"

from: uforwarder
to: uforwarder-client
evidence:
 - file: "uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/MockConsumerServiceStarter.java"
   contains "import com.uber.data.kafka.consumerproxy.client.grpc.ConsumerMetadata;"

from: uforwarder
to: fievel-common
evidence:
 - file: "uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java"
   contains "import com.uber.fievel.testing.base.FievelTestBase;"

from: uforwarder-container
to: uforwarder-client
evidence:
 - file: "uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java"
   contains "import com.uber.data.kafka.consumerproxy.client.grpc.ConsumerBytesServerMethodDefinition;"

from: uforwarder-container
to: uforwarder
evidence:
 - file: "uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java"
   contains "import static com.uber.data.kafka.consumerproxy.testutils.Constants.JOB_GROUP_ID_DELIMITER;"

from: uforwarder-container
to: fievel-common
evidence:
 - file: "uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java"
   contains "import com.uber.fievel.testing.base.FievelTestBase;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java"
   contains "import com.uber.data.kafka.instrumentation.Instrumentation;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java"
   contains "import com.uber.data.kafka.instrumentation.Instrumentation;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java"
   contains "import com.uber.data.kafka.instrumentation.Instrumentation;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcher.java"
   contains "import com.uber.data.kafka.instrumentation.Tags;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java"
   contains "import com.uber.data.kafka.instrumentation.BiConsumerConverter;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java"
   contains "import com.uber.data.kafka.instrumentation.BiConsumerConverter;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java"
   contains "import com.uber.data.kafka.instrumentation.Instrumentation;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator/LeaderSelector.java"
   contains "import com.uber.data.kafka.instrumentation.Instrumentation;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/BufferedWriteDecorator.java"
   contains "import com.uber.data.kafka.instrumentation.Instrumentation;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TTLDecorator.java"
   contains "import com.uber.data.kafka.instrumentation.Instrumentation;"

from: uforwarder-core
to: instrumentation
evidence:
 - file: "uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LoggingAndMetricsStoreDecorator.java"
   contains "import com.uber.data.kafka.instrumentation.Instrumentation;"

from: uforwarder-sample-consumer
to: uforwarder-client
evidence:
 - file: "uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java"
   contains "import com.uber.data.kafka.consumerproxy.client.grpc.ConsumerBytesServerMethodDefinition;"

from: uforwarder-sample-consumer
to: uforwarder-client
evidence:
 - file: "uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java"
   contains "import com.uber.data.kafka.consumerproxy.client.grpc.ConsumerMetadata;"