from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java" contains "import org.apache.kafka.clients.producer.Callback;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java" contains "import org.apache.kafka.clients.producer.Callback;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java" contains "import org.apache.kafka.clients.producer.ProducerConfig;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java" contains "import org.apache.kafka.clients.consumer.ConsumerConfig;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java" contains "import org.apache.kafka.common.Metric;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java" contains "import org.apache.kafka.common.security.auth.SecurityProtocol;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java" contains "import org.apache.kafka.common.KafkaException;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java" contains "import org.apache.kafka.common.utils.Exit;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java" contains "import org.apache.kafka.common.utils.ThreadUtils;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java" contains "import org.apache.kafka.common.utils.Exit;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/basic/BasicPlatform.java" contains "import org.apache.kafka.common.utils.Scheduler;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java" contains "import org.apache.kafka.common.KafkaFuture;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java" contains "import org.apache.kafka.common.KafkaException;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java" contains "import org.apache.kafka.common.utils.Exit;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java" contains "import org.apache.kafka.clients.admin.Admin;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/common/Platform.java" contains "import org.apache.kafka.common.utils.Scheduler;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/task/TaskWorker.java" contains "import org.apache.kafka.common.internals.KafkaFutureImpl;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskWorker.java" contains "import org.apache.kafka.common.internals.KafkaFutureImpl;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java" contains "import org.apache.kafka.clients.ApiVersions;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionWorker.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java" contains "import org.apache.kafka.clients.producer.Callback;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/workload/PartitionsSpec.java" contains "import org.apache.kafka.clients.admin.NewTopic;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java" contains "import org.apache.kafka.clients.consumer.ConsumerConfig;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpec.java" contains "import org.apache.kafka.common.TopicPartition;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/workload/TimeIntervalTransactionsGenerator.java" contains "import org.apache.kafka.common.utils.Time;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/workload/Throttle.java" contains "import org.apache.kafka.common.utils.Time;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java" contains "import org.apache.kafka.common.utils.ThreadUtils;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultWorker.java" contains "import org.apache.kafka.common.utils.Utils;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultWorker.java" contains "import org.apache.kafka.common.internals.KafkaFutureImpl;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultWorker.java" contains "import org.apache.kafka.common.internals.KafkaFutureImpl;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultWorker.java" contains "import org.apache.kafka.common.internals.KafkaFutureImpl;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerState.java" contains "import org.apache.kafka.common.KafkaException;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java" contains "import org.apache.kafka.common.utils.ThreadUtils;" from: tools to: clients evidence: - file: "tools/src/main/java/org/apache/kafka/trogdor/rest/RestExceptionMapper.java" contains "import org.apache.kafka.common.errors.InvalidRequestException;" from: core to: clients evidence: - file: "core/src/main/java/kafka/metrics/KafkaYammerMetrics.java" contains "import org.apache.kafka.common.metrics.JmxReporter;" from: core to: clients evidence: - file: "core/src/main/scala/kafka/tools/StreamsResetter.java" contains "import org.apache.kafka.clients.admin.Admin;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: streams to: clients evidence: - file: "streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java" contains "import org.apache.kafka.clients.producer.MockProducer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/KafkaClientSupplier.java" contains "import org.apache.kafka.clients.producer.Producer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java" contains "import org.apache.kafka.common.serialization.Serializer;" from: streams to: clients evidence: - file: "streams/test-utils/src/main/java/org/apache/kafka/streams/TestOutputTopic.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/Topology.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/StreamPartitioner.java" contains "import org.apache.kafka.clients.producer.internals.DefaultPartitioner;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestamp.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java" contains "import org.apache.kafka.common.metrics.MetricConfig;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/DefaultPartitionGrouper.java" contains "import org.apache.kafka.common.Cluster;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreListener.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/PartitionGrouper.java" contains "import org.apache.kafka.common.Cluster;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/RecordContext.java" contains "import org.apache.kafka.common.header.Headers;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java" contains "import org.apache.kafka.clients.producer.Producer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java" contains "import org.apache.kafka.clients.producer.Callback;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultKafkaClientSupplier.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java" contains "import org.apache.kafka.clients.producer.Producer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamPartitioner.java" contains "import org.apache.kafka.clients.producer.internals.DefaultPartitioner;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java" contains "import org.apache.kafka.clients.admin.Admin;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java" contains "import org.apache.kafka.clients.admin.Admin;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java" contains "import org.apache.kafka.clients.admin.Admin;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java" contains "import org.apache.kafka.clients.admin.Admin;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java" contains "import org.apache.kafka.clients.admin.Admin;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java" contains "import org.apache.kafka.clients.admin.Admin;" from: streams to: clients evidence: - file: "streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals/TestDriverProducer.java" contains "import org.apache.kafka.clients.consumer.ConsumerGroupMetadata;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java" contains "import org.apache.kafka.clients.consumer.Consumer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java" contains "import org.apache.kafka.clients.consumer.Consumer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java" contains "import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java" contains "import org.apache.kafka.clients.consumer.Consumer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestoreCallbackAdapter.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordBatchingStateRestoreCallback.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StampedRecord.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java" contains "import org.apache.kafka.clients.consumer.Consumer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRegister.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java" contains "import org.apache.kafka.common.Cluster;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/RestoringTasks.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java" contains "import org.apache.kafka.common.config.TopicConfig;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java" contains "import org.apache.kafka.common.config.TopicConfig;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.java" contains "import org.apache.kafka.common.config.TopicConfig;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java" contains "import org.apache.kafka.common.config.TopicConfig;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java" contains "import org.apache.kafka.common.serialization.ByteArraySerializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java" contains "import org.apache.kafka.common.serialization.Serializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextAdapter.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextReverseAdapter.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalApiProcessorContext.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java" contains "import org.apache.kafka.common.utils.Time;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java" contains "import static org.apache.kafka.common.utils.Utils.getNullableSizePrefixedArray;" from: streams to: clients evidence: - file: "streams/test-utils/src/main/java/org/apache/kafka/streams/internals/KeyValueStoreFacade.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/test-utils/src/main/java/org/apache/kafka/streams/internals/WindowStoreFacade.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java" contains "import org.apache.kafka.common.serialization.Serdes;" from: streams to: clients evidence: - file: "streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java" contains "import org.apache.kafka.common.serialization.Serdes;" from: streams to: clients evidence: - file: "streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java" contains "import org.apache.kafka.common.serialization.Serdes;" from: streams to: clients evidence: - file: "streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java" contains "import org.apache.kafka.clients.consumer.ConsumerConfig;" from: streams to: clients evidence: - file: "streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java" contains "import org.apache.kafka.clients.consumer.ConsumerConfig;" from: streams to: clients evidence: - file: "streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonTimestampExtractor.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java" contains "import org.apache.kafka.clients.consumer.ConsumerConfig;" from: streams to: clients evidence: - file: "streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java" contains "import org.apache.kafka.clients.consumer.ConsumerConfig;" from: streams to: clients evidence: - file: "streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java" contains "import org.apache.kafka.clients.consumer.ConsumerConfig;" from: streams to: clients evidence: - file: "streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java" contains "import org.apache.kafka.clients.consumer.ConsumerConfig;" from: streams to: clients evidence: - file: "streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java" contains "import org.apache.kafka.clients.consumer.ConsumerConfig;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java" contains "import org.apache.kafka.clients.producer.internals.DefaultPartitioner;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java" contains "import org.apache.kafka.clients.producer.internals.DefaultPartitioner;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java" contains "import org.apache.kafka.clients.producer.internals.DefaultPartitioner;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java" contains "import org.apache.kafka.common.config.ConfigException;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializer.java" contains "import org.apache.kafka.common.config.ConfigException;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java" contains "import org.apache.kafka.common.config.ConfigException;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java" contains "import org.apache.kafka.common.config.ConfigException;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/Grouped.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/Serialized.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/Consumed.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/Materialized.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullChangeSerde.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableSerializer.java" contains "import org.apache.kafka.common.serialization.Serializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedSerializer.java" contains "import org.apache.kafka.common.serialization.Serializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedInternal.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedDeserializer.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java" contains "import org.apache.kafka.common.serialization.Serdes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/StreamJoinedInternal.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java" contains "import org.apache.kafka.common.serialization.Serializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinedInternal.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/ProducedInternal.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java" contains "import org.apache.kafka.common.serialization.Serdes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/RepartitionedInternal.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/SerializedInternal.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/ConsumedInternal.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableDeserializer.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullTimeWindowedSerde.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedKeyValueStoreMaterializer.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImpl.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedStreamPartitioner.java" contains "import org.apache.kafka.common.utils.Utils;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplier.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionSendProcessorSupplier.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerde.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolverJoinProcessorSupplier.java" contains "import org.apache.kafka.common.serialization.Serializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchema.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper.java" contains "import org.apache.kafka.common.errors.UnsupportedVersionException;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java" contains "import org.apache.kafka.common.errors.UnsupportedVersionException;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionJoinForeignProcessorSupplier.java" contains "import org.apache.kafka.common.errors.UnsupportedVersionException;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSinkNode.java" contains "import org.apache.kafka.common.serialization.Serializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GroupedTableOperationRepartitionNode.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseRepartitionNode.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamToTableNode.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorSupplier.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java" contains "import org.apache.kafka.common.metrics.Gauge;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/CopartitionedTopicsEnforcer.java" contains "import org.apache.kafka.common.Cluster;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java" contains "import static org.apache.kafka.common.utils.Utils.diff;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java" contains "import org.apache.kafka.common.protocol.ByteBufferAccessor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/TimestampedBytesStore.java" contains "import static org.apache.kafka.clients.consumer.ConsumerRecord.NO_TIMESTAMP;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/HostInfo.java" contains "import org.apache.kafka.common.config.ConfigException;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/StateSerdes.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/Stores.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/WindowBytesStoreSupplier.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/KeyValueBytesStoreSupplier.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/SessionBytesStoreSupplier.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverters.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverter.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java" contains "import org.apache.kafka.common.metrics.Sensor.RecordingLevel;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/OffsetCheckpoint.java" contains "import org.apache.kafka.common.TopicPartition;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializer.java" contains "import org.apache.kafka.common.serialization.LongSerializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerde.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java" contains "import org.apache.kafka.common.serialization.Serdes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStore.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractStoreBuilder.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilder.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBuffer.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampDeserializer.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java" contains "import org.apache.kafka.common.serialization.Serde;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/BufferValue.java" contains "import static org.apache.kafka.common.utils.Utils.getNullableArray;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbSessionBytesStoreSupplier.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java" contains "import org.apache.kafka.common.utils.AbstractIterator;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionBytesStoreSupplier.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/FilteredCacheIterator.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/ContextualRecord.java" contains "import static org.apache.kafka.common.utils.Utils.getNullableSizePrefixedArray;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegment.java" contains "import org.apache.kafka.common.utils.Utils;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterator.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/OrderedBytes.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIterator.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreKeyValueIterator.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueByteStoreAdapter.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegment.java" contains "import org.apache.kafka.common.utils.Utils;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreIterator.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedCacheFunction.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowBytesStoreSupplier.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheSessionStoreIterator.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java" contains "import org.apache.kafka.common.utils.AbstractIterator;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFunction.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBRangeIterator.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/HasNextCondition.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueBytesStore.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/BufferKey.java" contains "import org.apache.kafka.common.utils.Bytes;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java" contains "import org.apache.kafka.common.header.Headers;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetrics.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java" contains "import org.apache.kafka.common.metrics.Gauge;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java" contains "import org.apache.kafka.common.metrics.Gauge;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTrigger.java" contains "import org.apache.kafka.common.utils.Time;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/internals/metrics/ClientMetrics.java" contains "import org.apache.kafka.common.metrics.Gauge;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java" contains "import org.apache.kafka.clients.producer.ProducerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/errors/ProductionExceptionHandler.java" contains "import org.apache.kafka.clients.producer.ProducerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/errors/TaskCorruptedException.java" contains "import org.apache.kafka.clients.consumer.InvalidOffsetException;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/errors/DeserializationExceptionHandler.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: streams to: clients evidence: - file: "streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java" contains "import org.apache.kafka.common.KafkaException;" from: streams to: connect evidence: - file: "streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java" contains "import org.apache.kafka.connect.json.JsonDeserializer;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRecordBenchmark.java" contains "import org.apache.kafka.clients.producer.ProducerRecord;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java" contains "import org.apache.kafka.common.TopicPartition;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/cache/LRUCacheBenchmark.java" contains "import org.apache.kafka.common.cache.LRUCache;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java" contains "import org.apache.kafka.common.metrics.Metrics;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/CheckpointBench.java" contains "import org.apache.kafka.common.metrics.Metrics;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchRequestBenchmark.java" contains "import org.apache.kafka.common.TopicPartition;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchResponseBenchmark.java" contains "import org.apache.kafka.common.TopicPartition;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/TopicBenchmark.java" contains "import org.apache.kafka.common.internals.Topic;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetchsession/FetchSessionBenchmark.java" contains "import org.apache.kafka.clients.FetchSessionHandler;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/consumer/SubscriptionStateBenchmark.java" contains "import org.apache.kafka.clients.Metadata;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java" contains "import org.apache.kafka.common.TopicPartition;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java" contains "import org.apache.kafka.common.TopicPartition;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/MetadataRequestBenchmark.java" contains "import org.apache.kafka.common.metrics.Metrics;" from: jmh-benchmarks to: clients evidence: - file: "jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/AclAuthorizerBenchmark.java" contains "import org.apache.kafka.server.authorizer.Action;" from: examples to: clients evidence: - file: "examples/src/main/java/kafka/examples/Producer.java" contains "import org.apache.kafka.clients.producer.Callback;" from: examples to: clients evidence: - file: "examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: examples to: clients evidence: - file: "examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java" contains "import org.apache.kafka.clients.admin.Admin;" from: examples to: clients evidence: - file: "examples/src/main/java/kafka/examples/Consumer.java" contains "import org.apache.kafka.clients.consumer.ConsumerConfig;" from: examples to: clients evidence: - file: "examples/src/main/java/kafka/examples/KafkaConsumerProducerDemo.java" contains "import org.apache.kafka.common.errors.TimeoutException;" from: log4j-appender to: clients evidence: - file: "log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java" contains "import static org.apache.kafka.clients.CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG;" from: connect to: clients evidence: - file: "connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkTask.java" contains "import org.apache.kafka.clients.consumer.OffsetAndMetadata;" from: connect to: clients evidence: - file: "connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkConnector.java" contains "import org.apache.kafka.common.config.AbstractConfig;" from: connect to: clients evidence: - file: "connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java" contains "import org.apache.kafka.common.config.AbstractConfig;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java" contains "import org.apache.kafka.clients.producer.RecordMetadata;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkTask.java" contains "import org.apache.kafka.clients.consumer.OffsetAndMetadata;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkTask.java" contains "import org.apache.kafka.clients.consumer.OffsetAndMetadata;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceConnector.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkConnector.java" contains "import org.apache.kafka.common.config.Config;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceConnector.java" contains "import org.apache.kafka.common.config.Config;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/TransformationDoc.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/PredicateDoc.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkConnector.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockConnector.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceConnector.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceTask.java" contains "import org.apache.kafka.common.utils.AppInfoParser;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectUtils.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreationGroup.java" contains "import org.apache.kafka.clients.admin.Admin;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java" contains "import org.apache.kafka.clients.admin.Admin;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java" contains "import org.apache.kafka.clients.ClientDnsLookup;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java" contains "import org.apache.kafka.clients.producer.ProducerConfig;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java" contains "import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTaskContext.java" contains "import org.apache.kafka.clients.consumer.KafkaConsumer;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java" contains "import org.apache.kafka.common.metrics.Measurable;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java" contains "import org.apache.kafka.common.MetricNameTemplate;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java" contains "import org.apache.kafka.common.config.AbstractConfig;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java" contains "import org.apache.kafka.common.config.AbstractConfig;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/PredicatedTransformation.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicCreationConfig.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfigTransformer.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java" contains "import org.apache.kafka.common.config.AbstractConfig;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java" contains "import org.apache.kafka.common.utils.ThreadUtils;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerInfo.java" contains "import org.apache.kafka.common.utils.Utils;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java" contains "import org.apache.kafka.common.utils.Exit;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneConfig.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java" contains "import org.apache.kafka.clients.GroupRebalanceConfig;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java" contains "import org.apache.kafka.clients.ApiVersions;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java" contains "import org.apache.kafka.common.config.provider.ConfigProvider;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java" contains "import org.apache.kafka.common.utils.LogContext;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/EagerAssignor.java" contains "import org.apache.kafka.common.utils.CircularIterator;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java" contains "import org.apache.kafka.common.protocol.types.ArrayOf;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeConnectProtocol.java" contains "import org.apache.kafka.common.protocol.types.ArrayOf;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ExtendedAssignment.java" contains "import org.apache.kafka.common.protocol.types.Struct;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java" contains "import org.apache.kafka.common.Configurable;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java" contains "import org.apache.kafka.common.config.provider.ConfigProvider;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanResult.java" contains "import org.apache.kafka.common.config.provider.ConfigProvider;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginType.java" contains "import org.apache.kafka.common.config.provider.ConfigProvider;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorReporter.java" contains "import org.apache.kafka.clients.producer.RecordMetadata;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/DeadLetterQueueReporter.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/LogReporter.java" contains "import org.apache.kafka.clients.producer.RecordMetadata;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporter.java" contains "import org.apache.kafka.clients.producer.RecordMetadata;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ProcessingContext.java" contains "import org.apache.kafka.clients.producer.RecordMetadata;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorHandlingMetrics.java" contains "import org.apache.kafka.common.metrics.Sensor;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java" contains "import org.apache.kafka.common.config.ConfigException;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/util/SSLUtils.java" contains "import org.apache.kafka.common.config.SslConfigs;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ServerInfo.java" contains "import org.apache.kafka.common.utils.AppInfoParser;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverterConfig.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverter.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/converters/ByteArrayConverter.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/converters/LongConverter.java" contains "import org.apache.kafka.common.serialization.LongDeserializer;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/converters/ShortConverter.java" contains "import org.apache.kafka.common.serialization.ShortDeserializer;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/converters/FloatConverter.java" contains "import org.apache.kafka.common.serialization.FloatDeserializer;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/converters/IntegerConverter.java" contains "import org.apache.kafka.common.serialization.IntegerDeserializer;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/converters/DoubleConverter.java" contains "import org.apache.kafka.common.serialization.DoubleDeserializer;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java" contains "import org.apache.kafka.common.utils.Exit;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java" contains "import org.apache.kafka.common.utils.Exit;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java" contains "import org.apache.kafka.clients.producer.ProducerConfig;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java" contains "import org.apache.kafka.clients.producer.ProducerConfig;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java" contains "import org.apache.kafka.clients.producer.ProducerConfig;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/storage/HeaderConverter.java" contains "import org.apache.kafka.common.Configurable;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/storage/SimpleHeaderConverter.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverter.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/storage/ConverterConfig.java" contains "import org.apache.kafka.common.config.AbstractConfig;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverterConfig.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryOffsetBackingStore.java" contains "import org.apache.kafka.common.utils.ThreadUtils;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java" contains "import org.apache.kafka.common.header.Headers;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/PrincipalConnectorClientConfigOverridePolicy.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/connector/policy/ConnectorClientConfigOverridePolicy.java" contains "import org.apache.kafka.common.Configurable;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/AllConnectorClientConfigOverridePolicy.java" contains "import org.apache.kafka.common.config.ConfigValue;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/NoneConnectorClientConfigOverridePolicy.java" contains "import org.apache.kafka.common.config.ConfigValue;" from: connect to: clients evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/AbstractConnectorClientConfigOverridePolicy.java" contains "import org.apache.kafka.common.config.ConfigValue;" from: connect to: clients evidence: - file: "connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/PropertyFileLoginModule.java" contains "import org.apache.kafka.common.config.ConfigException;" from: connect to: clients evidence: - file: "connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java" contains "import org.apache.kafka.common.config.ConfigException;" from: connect to: clients evidence: - file: "connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/BasicAuthSecurityRestExtension.java" contains "import org.apache.kafka.common.utils.AppInfoParser;" from: connect to: clients evidence: - file: "connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java" contains "import org.apache.kafka.common.cache.Cache;" from: connect to: clients evidence: - file: "connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java" contains "import org.apache.kafka.common.serialization.Deserializer;" from: connect to: clients evidence: - file: "connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java" contains "import org.apache.kafka.common.serialization.Serializer;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/Predicate.java" contains "import org.apache.kafka.common.Configurable;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKey.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/RecordIsTombstone.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/transforms/Transformation.java" contains "import org.apache.kafka.common.Configurable;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java" contains "import org.apache.kafka.common.cache.Cache;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java" contains "import org.apache.kafka.common.cache.Cache;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java" contains "import org.apache.kafka.common.cache.Cache;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java" contains "import org.apache.kafka.common.cache.Cache;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java" contains "import org.apache.kafka.common.cache.Cache;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java" contains "import org.apache.kafka.common.cache.Cache;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ValueToKey.java" contains "import org.apache.kafka.common.cache.Cache;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/RegexRouter.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Filter.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/RegexValidator.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SimpleConfig.java" contains "import org.apache.kafka.common.config.AbstractConfig;" from: connect to: clients evidence: - file: "connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidator.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java" contains "import org.apache.kafka.clients.producer.RecordMetadata;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java" contains "import org.apache.kafka.clients.consumer.OffsetAndMetadata;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java" contains "import org.apache.kafka.common.TopicPartition;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java" contains "import org.apache.kafka.common.record.TimestampType;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java" contains "import org.apache.kafka.common.config.Config;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/errors/ConnectException.java" contains "import org.apache.kafka.common.KafkaException;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/data/Values.java" contains "import org.apache.kafka.common.utils.Utils;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java" contains "import org.apache.kafka.common.utils.AbstractIterator;" from: connect to: clients evidence: - file: "connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtension.java" contains "import org.apache.kafka.common.Configurable;" from: connect to: clients evidence: - file: "connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java" contains "import org.apache.kafka.clients.CommonClientConfigs;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorUtils.java" contains "import org.apache.kafka.clients.producer.KafkaProducer;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceTask.java" contains "import org.apache.kafka.clients.producer.RecordMetadata;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java" contains "import org.apache.kafka.clients.producer.RecordMetadata;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatTask.java" contains "import org.apache.kafka.clients.producer.RecordMetadata;" from: connect to: clients evidence: - file: "connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClient.java" contains "import org.apache.kafka.clients.admin.AdminClient;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java" contains "import org.apache.kafka.clients.admin.AdminClient;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java" contains "import org.apache.kafka.clients.admin.AdminClient;" from: connect to: clients evidence: - file: "connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/RemoteClusterUtils.java" contains "import org.apache.kafka.clients.consumer.OffsetAndMetadata;" from: connect to: clients evidence: - file: "connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Heartbeat.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: connect to: clients evidence: - file: "connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Checkpoint.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java" contains "import org.apache.kafka.clients.consumer.KafkaConsumer;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSync.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMetrics.java" contains "import org.apache.kafka.common.metrics.Metrics;" from: connect to: clients evidence: - file: "connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/DefaultReplicationPolicy.java" contains "import org.apache.kafka.common.Configurable;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/ConfigPropertyFilter.java" contains "import org.apache.kafka.common.Configurable;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorTaskConfig.java" contains "import org.apache.kafka.common.TopicPartition;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/TopicFilter.java" contains "import org.apache.kafka.common.Configurable;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/GroupFilter.java" contains "import org.apache.kafka.common.Configurable;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultGroupFilter.java" contains "import org.apache.kafka.common.config.AbstractConfig;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultTopicFilter.java" contains "import org.apache.kafka.common.config.AbstractConfig;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultConfigPropertyFilter.java" contains "import org.apache.kafka.common.config.AbstractConfig;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatConnector.java" contains "import org.apache.kafka.common.config.ConfigDef;" from: connect to: clients evidence: - file: "connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java" contains "import org.apache.kafka.common.annotation.InterfaceStability;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java" contains "import org.apache.kafka.common.utils.Time;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/HeartbeatFormatter.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/CheckpointFormatter.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: connect to: clients evidence: - file: "connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/OffsetSyncFormatter.java" contains "import org.apache.kafka.clients.consumer.ConsumerRecord;" from: connect to: tools evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java" contains "import org.apache.kafka.tools.ThroughputThrottler;" from: connect to: tools evidence: - file: "connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java" contains "import org.apache.kafka.tools.ThroughputThrottler;"