Path	Lines of Code
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java	65
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java	76
connect/runtime/src/main/java/org/apache/kafka/connect/converters/ByteArrayConverter.java	45
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java	310
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractStatus.java	70
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java	63
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java	216
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java	290
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java	183
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	59
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderConnectorContext.java	18
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java	27
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java	13
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java	74
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	17
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java	39
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java	500
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java	200
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java	245
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	641
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTaskContext.java	90
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java	442
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTaskContext.java	13
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java	287
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java	95
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java	204
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java	192
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java	987
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	291
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java	154
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerRebalanceListener.java	7
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java	286
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	31
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginType.java	34
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java	251
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java	193
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java	106
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java	202
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	52
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	94
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	25
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	79
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java	247
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	86
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	261
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConfigBackingStore.java	28
connect/runtime/src/main/java/org/apache/kafka/connect/storage/FileOffsetBackingStore.java	72
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java	417
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java	176
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java	382
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java	117
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryOffsetBackingStore.java	80
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java	69
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetBackingStore.java	17
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReaderImpl.java	74
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java	101
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	21
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/SchemaSourceConnector.java	41
connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java	136
connect/runtime/src/main/java/org/apache/kafka/connect/tools/TransformationDoc.java	61
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	102
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	43
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java	51
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConvertingFutureCallback.java	55
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	211
connect/runtime/src/main/java/org/apache/kafka/connect/util/ReflectionsUtil.java	57
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	39
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java	145