clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java

connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java

connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java

clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java

clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java

clients/src/main/java/org/apache/kafka/common/config/ConfigValue.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigValueInfo.java

clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java
connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java

clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java
connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java

clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java

clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java

clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java

clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java

clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java

clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java

clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/clients/admin/Config.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java

connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/clients/admin/Config.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java

connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java

clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java

clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java

clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java

clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java

clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java

clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java

clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/clients/admin/Config.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java

connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java

clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java

clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java

clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java

clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java

clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java

clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java

clients/src/main/java/org/apache/kafka/clients/admin/Config.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java

clients/src/main/java/org/apache/kafka/clients/admin/Config.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java

clients/src/main/java/org/apache/kafka/clients/admin/Config.java
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java

clients/src/main/java/org/apache/kafka/clients/admin/Config.java
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java

clients/src/main/java/org/apache/kafka/clients/admin/Config.java
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java

clients/src/main/java/org/apache/kafka/clients/admin/Config.java
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java

clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java

clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java

clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java

clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java

clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java

clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java

clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java

clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java

clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java

clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java

clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java

clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java

clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java

clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java

clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java

clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java

clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java

clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java

clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java

connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java

connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java

connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java

connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java

connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java

connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java

connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java

connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java

connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java

connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java

connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java

connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java

connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java

connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java

clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java

clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java

connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java

connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java

connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java

connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java

connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java

connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java

clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java

connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java

connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java

connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java

connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java

connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java

clients/src/main/java/org/apache/kafka/common/security/token/delegation/TokenInformation.java
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorPluginInfo.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorPluginInfo.java
clients/src/main/java/org/apache/kafka/common/security/token/delegation/DelegationToken.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorPluginInfo.java
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorPluginInfo.java
clients/src/main/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPool.java

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorPluginInfo.java
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java

clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java