Path	Lines of Code
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java	113
connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java	30
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/data/ConnectSchema.java	231
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	34
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	210
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	136
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	824
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	419
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/sink/SinkConnector.java	5
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	36
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java	13
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java	4
connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java	86
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java	18
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java	5
connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java	9
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/util/ConnectorUtils.java	23