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