from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java"
   contains "import org.apache.flink.metrics.Counter;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java"
   contains "import org.apache.flink.metrics.Counter;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/metrics/KafkaMetricMutableWrapper.java"
   contains "import org.apache.flink.metrics.Gauge;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/metrics/KafkaMetricMutableWrapper.java"
   contains "import org.apache.flink.metrics.Gauge;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaShuffleFetcher.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaFetcher.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java"
   contains "import org.apache.flink.metrics.MetricGroup;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java"
   contains "import org.apache.flink.metrics.Gauge;"

from: flink-connectors
to: flink-metrics
evidence:
 - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricWrapper.java"
   contains "import org.apache.flink.metrics.Gauge;"