Path	Lines of Code
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java	343
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java	673
clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java	180
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java	192
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java	260
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java	353
clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java	145
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java	641
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java	987
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java	286
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/standalone/StandaloneHerder.java	261
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java	339
core/src/main/scala/kafka/consumer/SimpleConsumer.scala	119
core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala	765
core/src/main/scala/kafka/controller/KafkaController.scala	1104
core/src/main/scala/kafka/controller/PartitionStateMachine.scala	362
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala	723
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala	286
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala	926
core/src/main/scala/kafka/coordinator/transaction/DelayedTxnMarker.scala	21
core/src/main/scala/kafka/security/auth/Acl.scala	45
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala	444
core/src/main/scala/kafka/server/KafkaApis.scala	1829
core/src/main/scala/kafka/server/ReplicaManager.scala	1101
core/src/main/scala/kafka/tools/MirrorMaker.scala	583
core/src/main/scala/kafka/tools/SimpleConsumerPerformance.scala	123
core/src/main/scala/kafka/tools/StreamsResetter.java	500
release.py	275
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java	577
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java	584
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java	769
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java	710
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractStateManager.java	77
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java	190
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java	1507
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java	263
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java	523
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java	137
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java	134
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java	448
tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java	201