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