Path	Lines of Code
core/src/main/scala/kafka/Kafka.scala	67
core/src/main/scala/kafka/admin/AclCommand.scala	289
core/src/main/scala/kafka/admin/AdminClient.scala	439
core/src/main/scala/kafka/admin/AdminOperationException.scala	5
core/src/main/scala/kafka/admin/AdminUtils.scala	453
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala	52
core/src/main/scala/kafka/admin/BrokerMetadata.scala	2
core/src/main/scala/kafka/admin/ConfigCommand.scala	259
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala	892
core/src/main/scala/kafka/admin/DelegationTokenCommand.scala	158
core/src/main/scala/kafka/admin/DeleteRecordsCommand.scala	76
core/src/main/scala/kafka/admin/LogDirsCommand.scala	82
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala	100
core/src/main/scala/kafka/admin/RackAwareMode.scala	7
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala	529
core/src/main/scala/kafka/admin/TopicCommand.scala	339
core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala	180
core/src/main/scala/kafka/api/ApiUtils.scala	51
core/src/main/scala/kafka/api/ApiVersion.scala	118
core/src/main/scala/kafka/api/FetchRequest.scala	213
core/src/main/scala/kafka/api/FetchResponse.scala	115
core/src/main/scala/kafka/api/GroupCoordinatorRequest.scala	42
core/src/main/scala/kafka/api/GroupCoordinatorResponse.scala	33
core/src/main/scala/kafka/api/LeaderAndIsr.scala	21
core/src/main/scala/kafka/api/OffsetCommitRequest.scala	130
core/src/main/scala/kafka/api/OffsetCommitResponse.scala	53
core/src/main/scala/kafka/api/OffsetFetchRequest.scala	75
core/src/main/scala/kafka/api/OffsetFetchResponse.scala	74
core/src/main/scala/kafka/api/OffsetRequest.scala	94
core/src/main/scala/kafka/api/OffsetResponse.scala	70
core/src/main/scala/kafka/api/ProducerRequest.scala	109
core/src/main/scala/kafka/api/ProducerResponse.scala	75
core/src/main/scala/kafka/api/RequestOrResponse.scala	16
core/src/main/scala/kafka/api/TopicMetadata.scala	105
core/src/main/scala/kafka/api/TopicMetadataRequest.scala	46
core/src/main/scala/kafka/api/TopicMetadataResponse.scala	32
core/src/main/scala/kafka/client/ClientUtils.scala	151
core/src/main/scala/kafka/cluster/Broker.scala	32
core/src/main/scala/kafka/cluster/BrokerEndPoint.scala	37
core/src/main/scala/kafka/cluster/Cluster.scala	16
core/src/main/scala/kafka/cluster/EndPoint.scala	36
core/src/main/scala/kafka/cluster/Partition.scala	447
core/src/main/scala/kafka/cluster/Replica.scala	121
core/src/main/scala/kafka/common/AdminCommandFailedException.scala	5
core/src/main/scala/kafka/common/AppInfo.scala	30
core/src/main/scala/kafka/common/AuthorizationException.scala	12
core/src/main/scala/kafka/common/BaseEnum.scala	4
core/src/main/scala/kafka/common/BrokerEndPointNotAvailableException.scala	4
core/src/main/scala/kafka/common/BrokerNotAvailableException.scala	4
core/src/main/scala/kafka/common/ClientIdAndBroker.scala	9
core/src/main/scala/kafka/common/ClientIdAndTopic.scala	9
core/src/main/scala/kafka/common/Config.scala	15
core/src/main/scala/kafka/common/ConsumerCoordinatorNotAvailableException.scala	4
core/src/main/scala/kafka/common/ConsumerRebalanceFailedException.scala	4
core/src/main/scala/kafka/common/ControllerMovedException.scala	5
core/src/main/scala/kafka/common/ErrorMapping.scala	66
core/src/main/scala/kafka/common/FailedToSendMessageException.scala	3
core/src/main/scala/kafka/common/GenerateBrokerIdException.scala	6
core/src/main/scala/kafka/common/InconsistentBrokerIdException.scala	6
core/src/main/scala/kafka/common/InterBrokerSendThread.scala	53
core/src/main/scala/kafka/common/InvalidConfigException.scala	4
core/src/main/scala/kafka/common/InvalidMessageSizeException.scala	4
core/src/main/scala/kafka/common/InvalidOffsetException.scala	4
core/src/main/scala/kafka/common/KafkaException.scala	5
core/src/main/scala/kafka/common/KafkaStorageException.scala	6
core/src/main/scala/kafka/common/LeaderElectionNotNeededException.scala	5
core/src/main/scala/kafka/common/LeaderNotAvailableException.scala	5
core/src/main/scala/kafka/common/LogCleaningAbortedException.scala	3
core/src/main/scala/kafka/common/LongRef.scala	30
core/src/main/scala/kafka/common/MessageFormatter.scala	9
core/src/main/scala/kafka/common/MessageReader.scala	9
core/src/main/scala/kafka/common/MessageSetSizeTooLargeException.scala	4
core/src/main/scala/kafka/common/MessageSizeTooLargeException.scala	4
core/src/main/scala/kafka/common/MessageStreamsExistException.scala	3
core/src/main/scala/kafka/common/NoBrokersForPartitionException.scala	4
core/src/main/scala/kafka/common/NoEpochForPartitionException.scala	4
core/src/main/scala/kafka/common/NoReplicaOnlineException.scala	5
core/src/main/scala/kafka/common/NotAssignedReplicaException.scala	5
core/src/main/scala/kafka/common/NotCoordinatorForConsumerException.scala	4
core/src/main/scala/kafka/common/NotEnoughReplicasAfterAppendException.scala	4
core/src/main/scala/kafka/common/NotEnoughReplicasException.scala	4
core/src/main/scala/kafka/common/NotLeaderForPartitionException.scala	4
core/src/main/scala/kafka/common/OffsetMetadataAndError.scala	42
core/src/main/scala/kafka/common/OffsetMetadataTooLargeException.scala	4
core/src/main/scala/kafka/common/OffsetOutOfRangeException.scala	4
core/src/main/scala/kafka/common/OffsetsLoadInProgressException.scala	4
core/src/main/scala/kafka/common/QueueFullException.scala	4
core/src/main/scala/kafka/common/ReplicaNotAvailableException.scala	5
core/src/main/scala/kafka/common/RequestTimedOutException.scala	4
core/src/main/scala/kafka/common/StateChangeFailedException.scala	5
core/src/main/scala/kafka/common/StreamEndException.scala	3
core/src/main/scala/kafka/common/ThreadShutdownException.scala	3
core/src/main/scala/kafka/common/TopicAlreadyMarkedForDeletionException.scala	3
core/src/main/scala/kafka/common/TopicAndPartition.scala	6
core/src/main/scala/kafka/common/UnavailableProducerException.scala	4
core/src/main/scala/kafka/common/UnknownCodecException.scala	4
core/src/main/scala/kafka/common/UnknownException.scala	2
core/src/main/scala/kafka/common/UnknownMagicByteException.scala	4
core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala	4
core/src/main/scala/kafka/common/ZkNodeChangeNotificationListener.scala	90
core/src/main/scala/kafka/consumer/BaseConsumer.scala	118
core/src/main/scala/kafka/consumer/ConsumerConfig.scala	113
core/src/main/scala/kafka/consumer/ConsumerConnector.scala	36
core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala	119
core/src/main/scala/kafka/consumer/ConsumerFetcherThread.scala	112
core/src/main/scala/kafka/consumer/ConsumerIterator.scala	85
core/src/main/scala/kafka/consumer/ConsumerTopicStats.scala	36
core/src/main/scala/kafka/consumer/FetchRequestAndResponseStats.scala	46
core/src/main/scala/kafka/consumer/FetchedDataChunk.scala	6
core/src/main/scala/kafka/consumer/KafkaStream.scala	22
core/src/main/scala/kafka/consumer/PartitionAssignor.scala	96
core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala	48
core/src/main/scala/kafka/consumer/SimpleConsumer.scala	119
core/src/main/scala/kafka/consumer/TopicCount.scala	104
core/src/main/scala/kafka/consumer/TopicEventHandler.scala	5
core/src/main/scala/kafka/consumer/TopicFilter.scala	37
core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala	765
core/src/main/scala/kafka/consumer/ZookeeperTopicEventWatcher.scala	66
core/src/main/scala/kafka/consumer/package.html	1
core/src/main/scala/kafka/controller/ControllerChannelManager.scala	420
core/src/main/scala/kafka/controller/ControllerContext.scala	70
core/src/main/scala/kafka/controller/ControllerEventManager.scala	52
core/src/main/scala/kafka/controller/ControllerState.scala	54
core/src/main/scala/kafka/controller/KafkaController.scala	1104
core/src/main/scala/kafka/controller/PartitionStateMachine.scala	362
core/src/main/scala/kafka/controller/ReplicaStateMachine.scala	296
core/src/main/scala/kafka/controller/StateChangeLogger.scala	19
core/src/main/scala/kafka/controller/TopicDeletionManager.scala	185
core/src/main/scala/kafka/coordinator/group/DelayedHeartbeat.scala	12
core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala	35
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/group/MemberMetadata.scala	66
core/src/main/scala/kafka/coordinator/group/OffsetConfig.scala	24
core/src/main/scala/kafka/coordinator/transaction/DelayedTxnMarker.scala	21
core/src/main/scala/kafka/coordinator/transaction/ProducerIdManager.scala	104
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala	411
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala	178
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala	300
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala	139
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala	267
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala	463
core/src/main/scala/kafka/javaapi/FetchRequest.scala	42
core/src/main/scala/kafka/javaapi/FetchResponse.scala	19
core/src/main/scala/kafka/javaapi/GroupCoordinatorResponse.scala	23
core/src/main/scala/kafka/javaapi/Implicits.scala	24
core/src/main/scala/kafka/javaapi/OffsetCommitRequest.scala	34
core/src/main/scala/kafka/javaapi/OffsetCommitResponse.scala	14
core/src/main/scala/kafka/javaapi/OffsetFetchRequest.scala	33
core/src/main/scala/kafka/javaapi/OffsetFetchResponse.scala	10
core/src/main/scala/kafka/javaapi/OffsetRequest.scala	26
core/src/main/scala/kafka/javaapi/OffsetResponse.scala	19
core/src/main/scala/kafka/javaapi/TopicMetadata.scala	33
core/src/main/scala/kafka/javaapi/TopicMetadataRequest.scala	39
core/src/main/scala/kafka/javaapi/TopicMetadataResponse.scala	17
core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java	23
core/src/main/scala/kafka/javaapi/consumer/ConsumerRebalanceListener.java	9
core/src/main/scala/kafka/javaapi/consumer/SimpleConsumer.scala	40
core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala	58
core/src/main/scala/kafka/javaapi/message/ByteBufferMessageSet.scala	35
core/src/main/scala/kafka/javaapi/message/MessageSet.scala	14
core/src/main/scala/kafka/javaapi/producer/Producer.scala	18
core/src/main/scala/kafka/log/AbstractIndex.scala	166
core/src/main/scala/kafka/log/CleanerConfig.scala	11
core/src/main/scala/kafka/log/CorruptIndexException.scala	2
core/src/main/scala/kafka/log/IndexEntry.scala	17
core/src/main/scala/kafka/log/Log.scala	1086
core/src/main/scala/kafka/log/LogCleaner.scala	615
core/src/main/scala/kafka/log/LogCleanerManager.scala	241
core/src/main/scala/kafka/log/LogConfig.scala	262
core/src/main/scala/kafka/log/LogManager.scala	682
core/src/main/scala/kafka/log/LogSegment.scala	334
core/src/main/scala/kafka/log/LogValidator.scala	272
core/src/main/scala/kafka/log/OffsetIndex.scala	100
core/src/main/scala/kafka/log/OffsetMap.scala	99
core/src/main/scala/kafka/log/ProducerStateManager.scala	503
core/src/main/scala/kafka/log/TimeIndex.scala	112
core/src/main/scala/kafka/log/TransactionIndex.scala	165
core/src/main/scala/kafka/log/package.html	4
core/src/main/scala/kafka/message/ByteBufferMessageSet.scala	79
core/src/main/scala/kafka/message/CompressionCodec.scala	67
core/src/main/scala/kafka/message/InvalidMessageException.scala	6
core/src/main/scala/kafka/message/Message.scala	172
core/src/main/scala/kafka/message/MessageAndMetadata.scala	14
core/src/main/scala/kafka/message/MessageAndOffset.scala	25
core/src/main/scala/kafka/message/MessageLengthException.scala	2
core/src/main/scala/kafka/message/MessageSet.scala	46
core/src/main/scala/kafka/message/package.html	1
core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala	52
core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala	6
core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala	131
core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala	37
core/src/main/scala/kafka/metrics/KafkaTimer.scala	9
core/src/main/scala/kafka/network/BlockingChannel.scala	92
core/src/main/scala/kafka/network/RequestChannel.scala	336
core/src/main/scala/kafka/network/RequestOrResponseSend.scala	29
core/src/main/scala/kafka/network/SocketServer.scala	566
core/src/main/scala/kafka/network/package.html	11
core/src/main/scala/kafka/producer/BaseProducer.scala	41
core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala	69
core/src/main/scala/kafka/producer/ByteArrayPartitioner.scala	10
core/src/main/scala/kafka/producer/DefaultPartitioner.scala	10
core/src/main/scala/kafka/producer/KeyedMessage.scala	18
core/src/main/scala/kafka/producer/Partitioner.scala	6
core/src/main/scala/kafka/producer/Producer.scala	101
core/src/main/scala/kafka/producer/ProducerClosedException.scala	4
core/src/main/scala/kafka/producer/ProducerConfig.scala	48
core/src/main/scala/kafka/producer/ProducerPool.scala	59
core/src/main/scala/kafka/producer/ProducerRequestStats.scala	36
core/src/main/scala/kafka/producer/ProducerStats.scala	22
core/src/main/scala/kafka/producer/ProducerTopicStats.scala	37
core/src/main/scala/kafka/producer/SyncProducer.scala	116
core/src/main/scala/kafka/producer/SyncProducerConfig.scala	29
core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala	13
core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala	292
core/src/main/scala/kafka/producer/async/EventHandler.scala	7
core/src/main/scala/kafka/producer/async/IllegalQueueStateException.scala	5
core/src/main/scala/kafka/producer/async/MissingConfigException.scala	5
core/src/main/scala/kafka/producer/async/ProducerSendThread.scala	78
core/src/main/scala/kafka/security/CredentialProvider.scala	29
core/src/main/scala/kafka/security/SecurityUtils.scala	29
core/src/main/scala/kafka/security/auth/Acl.scala	45
core/src/main/scala/kafka/security/auth/Authorizer.scala	14
core/src/main/scala/kafka/security/auth/Operation.scala	59
core/src/main/scala/kafka/security/auth/PermissionType.scala	22
core/src/main/scala/kafka/security/auth/Resource.scala	19
core/src/main/scala/kafka/security/auth/ResourceType.scala	41
core/src/main/scala/kafka/security/auth/SimpleAclAuthorizer.scala	235
core/src/main/scala/kafka/serializer/Decoder.scala	29
core/src/main/scala/kafka/serializer/Encoder.scala	35
core/src/main/scala/kafka/server/AbstractFetcherManager.scala	139
core/src/main/scala/kafka/server/AbstractFetcherThread.scala	306
core/src/main/scala/kafka/server/AdminManager.scala	365
core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala	56
core/src/main/scala/kafka/server/BrokerStates.scala	17
core/src/main/scala/kafka/server/ClientQuotaManager.scala	320
core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala	53
core/src/main/scala/kafka/server/ConfigHandler.scala	145
core/src/main/scala/kafka/server/DelayedCreatePartitions.scala	45
core/src/main/scala/kafka/server/DelayedDeleteRecords.scala	77
core/src/main/scala/kafka/server/DelayedDeleteTopics.scala	35
core/src/main/scala/kafka/server/DelayedFetch.scala	113
core/src/main/scala/kafka/server/DelayedOperation.scala	213
core/src/main/scala/kafka/server/DelayedOperationKey.scala	21
core/src/main/scala/kafka/server/DelayedProduce.scala	84
core/src/main/scala/kafka/server/DelegationTokenManager.scala	345
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala	444
core/src/main/scala/kafka/server/DynamicConfig.scala	67
core/src/main/scala/kafka/server/DynamicConfigManager.scala	100
core/src/main/scala/kafka/server/FetchDataInfo.scala	7
core/src/main/scala/kafka/server/KafkaApis.scala	1829
core/src/main/scala/kafka/server/KafkaConfig.scala	1063
core/src/main/scala/kafka/server/KafkaRequestHandler.scala	182
core/src/main/scala/kafka/server/KafkaServer.scala	480
core/src/main/scala/kafka/server/KafkaServerStartable.scala	34
core/src/main/scala/kafka/server/LogDirFailureChannel.scala	15
core/src/main/scala/kafka/server/LogOffsetMetadata.scala	40
core/src/main/scala/kafka/server/MetadataCache.scala	181
core/src/main/scala/kafka/server/QuotaFactory.scala	79
core/src/main/scala/kafka/server/ReplicaAlterLogDirsManager.scala	18
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala	200
core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala	82
core/src/main/scala/kafka/server/ReplicaFetcherManager.scala	19
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala	269
core/src/main/scala/kafka/server/ReplicaManager.scala	1101
core/src/main/scala/kafka/server/ReplicationQuotaManager.scala	103
core/src/main/scala/kafka/server/SensorAccess.scala	26
core/src/main/scala/kafka/server/ThrottledResponse.scala	16
core/src/main/scala/kafka/server/checkpoints/CheckpointFile.scala	99
core/src/main/scala/kafka/server/checkpoints/LeaderEpochCheckpointFile.scala	34
core/src/main/scala/kafka/server/checkpoints/OffsetCheckpointFile.scala	33
core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala	114
core/src/main/scala/kafka/server/package.html	1
core/src/main/scala/kafka/tools/ConsoleConsumer.scala	495
core/src/main/scala/kafka/tools/ConsoleProducer.scala	287
core/src/main/scala/kafka/tools/ConsumerPerformance.scala	349
core/src/main/scala/kafka/tools/DumpLogSegments.scala	406
core/src/main/scala/kafka/tools/EndToEndLatency.scala	90
core/src/main/scala/kafka/tools/ExportZkOffsets.scala	77
core/src/main/scala/kafka/tools/GetOffsetShell.scala	81
core/src/main/scala/kafka/tools/ImportZkOffsets.scala	58
core/src/main/scala/kafka/tools/JmxTool.scala	149
core/src/main/scala/kafka/tools/MirrorMaker.scala	583
core/src/main/scala/kafka/tools/PerfConfig.scala	22
core/src/main/scala/kafka/tools/ProducerPerformance.scala	257
core/src/main/scala/kafka/tools/ReplayLogProducer.scala	128
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala	319
core/src/main/scala/kafka/tools/SimpleConsumerPerformance.scala	123
core/src/main/scala/kafka/tools/SimpleConsumerShell.scala	219
core/src/main/scala/kafka/tools/StateChangeLogMerger.scala	129
core/src/main/scala/kafka/tools/StreamsResetter.java	500
core/src/main/scala/kafka/tools/UpdateOffsetsInZK.scala	62
core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala	96
core/src/main/scala/kafka/tools/ZooKeeperMainWrapper.scala	15
core/src/main/scala/kafka/utils/Annotations.scala	5
core/src/main/scala/kafka/utils/CommandLineUtils.scala	41
core/src/main/scala/kafka/utils/CoreUtils.scala	175
core/src/main/scala/kafka/utils/DelayedItem.scala	15
core/src/main/scala/kafka/utils/Exit.scala	23
core/src/main/scala/kafka/utils/FileLock.scala	40
core/src/main/scala/kafka/utils/Implicits.scala	12
core/src/main/scala/kafka/utils/IteratorTemplate.scala	52
core/src/main/scala/kafka/utils/Json.scala	40
core/src/main/scala/kafka/utils/KafkaScheduler.scala	75
core/src/main/scala/kafka/utils/Log4jController.scala	50
core/src/main/scala/kafka/utils/Logging.scala	40
core/src/main/scala/kafka/utils/Mx4jLoader.scala	37
core/src/main/scala/kafka/utils/NotNothing.scala	8
core/src/main/scala/kafka/utils/Pool.scala	47
core/src/main/scala/kafka/utils/ReplicationUtils.scala	33
core/src/main/scala/kafka/utils/ShutdownableThread.scala	60
core/src/main/scala/kafka/utils/Throttler.scala	65
core/src/main/scala/kafka/utils/ToolsUtils.scala	37
core/src/main/scala/kafka/utils/VerifiableProperties.scala	118
core/src/main/scala/kafka/utils/ZkUtils.scala	915
core/src/main/scala/kafka/utils/json/DecodeJson.scala	69
core/src/main/scala/kafka/utils/json/JsonArray.scala	7
core/src/main/scala/kafka/utils/json/JsonObject.scala	13
core/src/main/scala/kafka/utils/json/JsonValue.scala	40
core/src/main/scala/kafka/utils/timer/Timer.scala	71
core/src/main/scala/kafka/utils/timer/TimerTask.scala	21
core/src/main/scala/kafka/utils/timer/TimerTaskList.scala	103
core/src/main/scala/kafka/utils/timer/TimingWheel.scala	49
core/src/main/scala/kafka/zk/AdminZkClient.scala	248
core/src/main/scala/kafka/zk/KafkaZkClient.scala	901
core/src/main/scala/kafka/zk/ZkData.scala	406
core/src/main/scala/kafka/zookeeper/ZooKeeperClient.scala	324