Path	Lines of Code
connect/api/src/main/java/org/apache/kafka/connect/components/Versioned.java	4
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java	106
connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java	39
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectorContext.java	5
connect/api/src/main/java/org/apache/kafka/connect/connector/Task.java	7
connect/api/src/main/java/org/apache/kafka/connect/connector/policy/ConnectorClientConfigOverridePolicy.java	7
connect/api/src/main/java/org/apache/kafka/connect/connector/policy/ConnectorClientConfigRequest.java	41
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java	239
connect/api/src/main/java/org/apache/kafka/connect/data/Date.java	32
connect/api/src/main/java/org/apache/kafka/connect/data/Decimal.java	35
connect/api/src/main/java/org/apache/kafka/connect/data/Field.java	42
connect/api/src/main/java/org/apache/kafka/connect/data/Schema.java	72
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaAndValue.java	36
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaBuilder.java	228
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaProjector.java	150
connect/api/src/main/java/org/apache/kafka/connect/data/Struct.java	138
connect/api/src/main/java/org/apache/kafka/connect/data/Time.java	33
connect/api/src/main/java/org/apache/kafka/connect/data/Timestamp.java	21
connect/api/src/main/java/org/apache/kafka/connect/data/Values.java	931
connect/api/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java	12
connect/api/src/main/java/org/apache/kafka/connect/errors/ConnectException.java	13
connect/api/src/main/java/org/apache/kafka/connect/errors/DataException.java	12
connect/api/src/main/java/org/apache/kafka/connect/errors/IllegalWorkerStateException.java	12
connect/api/src/main/java/org/apache/kafka/connect/errors/NotFoundException.java	12
connect/api/src/main/java/org/apache/kafka/connect/errors/RetriableException.java	12
connect/api/src/main/java/org/apache/kafka/connect/errors/SchemaBuilderException.java	12
connect/api/src/main/java/org/apache/kafka/connect/errors/SchemaProjectorException.java	12
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeader.java	64
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java	404
connect/api/src/main/java/org/apache/kafka/connect/header/Header.java	9
connect/api/src/main/java/org/apache/kafka/connect/header/Headers.java	44
connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java	42
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectClusterDetails.java	4
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectClusterState.java	13
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java	61
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorState.java	14
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorType.java	11
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java	36
connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtension.java	9
connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtensionContext.java	7
connect/api/src/main/java/org/apache/kafka/connect/sink/ErrantRecordReporter.java	6
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java	9
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnectorContext.java	4
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java	64
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java	37
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java	17
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java	8
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnectorContext.java	6
connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java	84
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java	25
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java	7
connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java	16
connect/api/src/main/java/org/apache/kafka/connect/storage/ConverterConfig.java	22
connect/api/src/main/java/org/apache/kafka/connect/storage/ConverterType.java	32
connect/api/src/main/java/org/apache/kafka/connect/storage/HeaderConverter.java	12
connect/api/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReader.java	7
connect/api/src/main/java/org/apache/kafka/connect/storage/SimpleHeaderConverter.java	54
connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverter.java	65
connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverterConfig.java	27
connect/api/src/main/java/org/apache/kafka/connect/transforms/Transformation.java	11
connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/Predicate.java	10
connect/api/src/main/java/org/apache/kafka/connect/util/ConnectorUtils.java	23
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/BasicAuthSecurityRestExtension.java	27
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java	110
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/PropertyFileLoginModule.java	113
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkConnector.java	49
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkTask.java	67
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java	64
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java	183
connect/json/src/main/java/org/apache/kafka/connect/json/DecimalFormat.java	5
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java	656
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java	63
connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java	34
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSchema.java	58
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java	32
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Checkpoint.java	140
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/DefaultReplicationPolicy.java	43
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Heartbeat.java	105
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClient.java	168
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java	82
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/RemoteClusterUtils.java	41
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java	20
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/SourceAndTarget.java	27
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/ConfigPropertyFilter.java	12
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultConfigPropertyFilter.java	48
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultGroupFilter.java	58
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultTopicFilter.java	58
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/GroupFilter.java	12
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java	125
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java	252
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java	529
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatConnector.java	50
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatTask.java	56
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java	223
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java	172
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMetrics.java	159
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java	350
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceTask.java	241
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorTaskConfig.java	50
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorUtils.java	78
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSync.java	83
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java	53
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/Scheduler.java	85
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/TopicFilter.java	12
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/CheckpointFormatter.java	11
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/HeartbeatFormatter.java	11
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/OffsetSyncFormatter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java	90
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java	90
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/AbstractConnectorClientConfigOverridePolicy.java	30
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/AllConnectorClientConfigOverridePolicy.java	20
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/NoneConnectorClientConfigOverridePolicy.java	20
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/PrincipalConnectorClientConfigOverridePolicy.java	29
connect/runtime/src/main/java/org/apache/kafka/connect/converters/ByteArrayConverter.java	45
connect/runtime/src/main/java/org/apache/kafka/connect/converters/DoubleConverter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/converters/FloatConverter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/converters/IntegerConverter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/converters/LongConverter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverter.java	81
connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverterConfig.java	13
connect/runtime/src/main/java/org/apache/kafka/connect/converters/ShortConverter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java	537
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractStatus.java	71
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/CloseableConnectorContext.java	7
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java	74
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java	221
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java	355
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java	411
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorStatus.java	17
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java	76
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderConnectorContext.java	38
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderRequest.java	4
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java	44
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/PredicatedTransformation.java	50
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java	31
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java	125
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java	130
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java	79
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/StateTracker.java	96
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TargetState.java	5
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java	23
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskStatus.java	18
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicCreationConfig.java	112
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicStatus.java	57
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java	54
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java	843
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java	441
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfigTransformer.java	77
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java	414
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerInfo.java	63
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java	688
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTaskContext.java	128
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java	568
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTaskContext.java	25
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java	311
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java	172
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectAssignor.java	10
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java	209
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocolCompatibility.java	70
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java	383
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java	1446
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/EagerAssignor.java	127
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ExtendedAssignment.java	189
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ExtendedWorkerState.java	19
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java	545
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeConnectProtocol.java	124
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/NotAssignedException.java	6
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/NotLeaderException.java	6
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/RebalanceNeededException.java	7
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/RequestTargetException.java	20
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java	457
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java	181
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerRebalanceListener.java	7
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/DeadLetterQueueReporter.java	155
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorHandlingMetrics.java	68
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorReporter.java	8
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/LogReporter.java	40
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/Operation.java	4
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ProcessingContext.java	136
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java	185
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/Stage.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ToleranceType.java	9
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporter.java	110
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/health/ConnectClusterDetailsImpl.java	12
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/health/ConnectClusterStateImpl.java	86
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java	405
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java	50
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginDesc.java	80
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanResult.java	76
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginType.java	40
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java	268
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java	355
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/ConnectRestConfigurable.java	96
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/ConnectRestExtensionContextImpl.java	23
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java	99
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java	131
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java	351
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ActiveTopicsInfo.java	20
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigInfo.java	39
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigInfos.java	69
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigKeyInfo.java	135
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConfigValueInfo.java	76
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorInfo.java	53
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorPluginInfo.java	62
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorStateInfo.java	101
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorType.java	28
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequest.java	34
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ErrorMessage.java	33
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ServerInfo.java	32
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/TaskInfo.java	33
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/errors/BadRequestException.java	7
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/errors/ConnectExceptionMapper.java	49
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/errors/ConnectRestException.java	39
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java	92
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java	337
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResource.java	128
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/RootResource.java	20
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/util/SSLUtils.java	96
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneConfig.java	19
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java	352
connect/runtime/src/main/java/org/apache/kafka/connect/storage/CloseableOffsetStorageReader.java	8
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConfigBackingStore.java	31
connect/runtime/src/main/java/org/apache/kafka/connect/storage/FileOffsetBackingStore.java	70
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java	512
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java	192
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java	540
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java	130
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryOffsetBackingStore.java	78
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java	100
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetBackingStore.java	14
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReaderImpl.java	119
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java	102
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetUtils.java	31
connect/runtime/src/main/java/org/apache/kafka/connect/storage/StatusBackingStore.java	26
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockConnector.java	71
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkConnector.java	51
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkTask.java	53
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceConnector.java	51
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceTask.java	45
connect/runtime/src/main/java/org/apache/kafka/connect/tools/PredicateDoc.java	55
connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceConnector.java	41
connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java	135
connect/runtime/src/main/java/org/apache/kafka/connect/tools/TransformationDoc.java	63
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkConnector.java	41
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkTask.java	74
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceConnector.java	41
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java	103
connect/runtime/src/main/java/org/apache/kafka/connect/util/Callback.java	4
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectUtils.java	66
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java	50
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConvertingFutureCallback.java	87
connect/runtime/src/main/java/org/apache/kafka/connect/util/FutureCallback.java	13
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java	229
connect/runtime/src/main/java/org/apache/kafka/connect/util/LoggingContext.java	81
connect/runtime/src/main/java/org/apache/kafka/connect/util/SafeObjectInputStream.java	43
connect/runtime/src/main/java/org/apache/kafka/connect/util/ShutdownableThread.java	58
connect/runtime/src/main/java/org/apache/kafka/connect/util/SinkUtils.java	7
connect/runtime/src/main/java/org/apache/kafka/connect/util/Table.java	42
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java	336
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreation.java	63
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreationGroup.java	87
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java	383
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java	80
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Filter.java	24
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java	218
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java	85
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java	211
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java	162
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/RegexRouter.java	46
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java	173
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java	101
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java	357
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java	69
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ValueToKey.java	79
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKey.java	38
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/RecordIsTombstone.java	26
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.java	48
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidator.java	16
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/RegexValidator.java	18
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/Requirements.java	48
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java	19
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SimpleConfig.java	9