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;"