Path	Lines of Code
core/src/main/java/kafka/metrics/FilteringJmxReporter.java	36
core/src/main/java/kafka/metrics/KafkaYammerMetrics.java	38
core/src/main/scala/kafka/Kafka.scala	55
core/src/main/scala/kafka/admin/AclCommand.scala	516
core/src/main/scala/kafka/admin/AdminOperationException.scala	5
core/src/main/scala/kafka/admin/AdminUtils.scala	120
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala	280
core/src/main/scala/kafka/admin/BrokerMetadata.scala	2
core/src/main/scala/kafka/admin/ConfigCommand.scala	706
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala	1008
core/src/main/scala/kafka/admin/DelegationTokenCommand.scala	162
core/src/main/scala/kafka/admin/DeleteRecordsCommand.scala	97
core/src/main/scala/kafka/admin/LeaderElectionCommand.scala	232
core/src/main/scala/kafka/admin/LogDirsCommand.scala	88
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala	244
core/src/main/scala/kafka/admin/RackAwareMode.scala	7
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala	1234
core/src/main/scala/kafka/admin/TopicCommand.scala	649
core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala	229
core/src/main/scala/kafka/api/ApiUtils.scala	39
core/src/main/scala/kafka/api/ApiVersion.scala	252
core/src/main/scala/kafka/api/LeaderAndIsr.scala	26
core/src/main/scala/kafka/api/Request.scala	16
core/src/main/scala/kafka/api/package.scala	27
core/src/main/scala/kafka/cluster/Broker.scala	57
core/src/main/scala/kafka/cluster/BrokerEndPoint.scala	40
core/src/main/scala/kafka/cluster/EndPoint.scala	39
core/src/main/scala/kafka/cluster/Partition.scala	827
core/src/main/scala/kafka/cluster/Replica.scala	54
core/src/main/scala/kafka/common/AdminCommandFailedException.scala	5
core/src/main/scala/kafka/common/BaseEnum.scala	4
core/src/main/scala/kafka/common/BrokerEndPointNotAvailableException.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	16
core/src/main/scala/kafka/common/GenerateBrokerIdException.scala	6
core/src/main/scala/kafka/common/InconsistentBrokerIdException.scala	6
core/src/main/scala/kafka/common/InconsistentBrokerMetadataException.scala	6
core/src/main/scala/kafka/common/InconsistentClusterIdException.scala	6
core/src/main/scala/kafka/common/IndexOffsetOverflowException.scala	4
core/src/main/scala/kafka/common/InterBrokerSendThread.scala	152
core/src/main/scala/kafka/common/KafkaException.scala	5
core/src/main/scala/kafka/common/LogCleaningAbortedException.scala	3
core/src/main/scala/kafka/common/LogSegmentOffsetOverflowException.scala	5
core/src/main/scala/kafka/common/LongRef.scala	30
core/src/main/scala/kafka/common/MessageFormatter.scala	4
core/src/main/scala/kafka/common/MessageReader.scala	9
core/src/main/scala/kafka/common/NoEpochForPartitionException.scala	4
core/src/main/scala/kafka/common/OffsetAndMetadata.scala	27
core/src/main/scala/kafka/common/OffsetsOutOfOrderException.scala	3
core/src/main/scala/kafka/common/RecordValidationException.scala	7
core/src/main/scala/kafka/common/StateChangeFailedException.scala	5
core/src/main/scala/kafka/common/ThreadShutdownException.scala	3
core/src/main/scala/kafka/common/TopicAlreadyMarkedForDeletionException.scala	3
core/src/main/scala/kafka/common/UnexpectedAppendOffsetException.scala	5
core/src/main/scala/kafka/common/UnknownCodecException.scala	4
core/src/main/scala/kafka/common/ZkNodeChangeNotificationListener.scala	99
core/src/main/scala/kafka/consumer/BaseConsumerRecord.scala	14
core/src/main/scala/kafka/controller/ControllerChannelManager.scala	569
core/src/main/scala/kafka/controller/ControllerContext.scala	363
core/src/main/scala/kafka/controller/ControllerEventManager.scala	114
core/src/main/scala/kafka/controller/ControllerState.scala	69
core/src/main/scala/kafka/controller/Election.scala	90
core/src/main/scala/kafka/controller/KafkaController.scala	1519
core/src/main/scala/kafka/controller/PartitionStateMachine.scala	405
core/src/main/scala/kafka/controller/ReplicaStateMachine.scala	334
core/src/main/scala/kafka/controller/StateChangeLogger.scala	19
core/src/main/scala/kafka/controller/TopicDeletionManager.scala	191
core/src/main/scala/kafka/coordinator/group/DelayedHeartbeat.scala	12
core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala	39
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala	1049
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala	514
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala	1157
core/src/main/scala/kafka/coordinator/group/MemberMetadata.scala	83
core/src/main/scala/kafka/coordinator/group/OffsetConfig.scala	24
core/src/main/scala/kafka/coordinator/transaction/ProducerIdManager.scala	104
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala	469
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala	192
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala	321
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala	140
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala	309
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala	484
core/src/main/scala/kafka/log/AbstractIndex.scala	200
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/LazyIndex.scala	89
core/src/main/scala/kafka/log/Log.scala	1638
core/src/main/scala/kafka/log/LogCleaner.scala	717
core/src/main/scala/kafka/log/LogCleanerManager.scala	392
core/src/main/scala/kafka/log/LogConfig.scala	301
core/src/main/scala/kafka/log/LogManager.scala	840
core/src/main/scala/kafka/log/LogSegment.scala	400
core/src/main/scala/kafka/log/LogValidator.scala	412
core/src/main/scala/kafka/log/OffsetIndex.scala	107
core/src/main/scala/kafka/log/OffsetMap.scala	99
core/src/main/scala/kafka/log/ProducerStateManager.scala	516
core/src/main/scala/kafka/log/TimeIndex.scala	117
core/src/main/scala/kafka/log/TransactionIndex.scala	168
core/src/main/scala/kafka/message/CompressionCodec.scala	74
core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala	51
core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala	10
core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala	58
core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala	38
core/src/main/scala/kafka/metrics/KafkaTimer.scala	9
core/src/main/scala/kafka/metrics/LinuxIoMetricsCollector.scala	59
core/src/main/scala/kafka/network/RequestChannel.scala	396
core/src/main/scala/kafka/network/SocketServer.scala	1055
core/src/main/scala/kafka/security/CredentialProvider.scala	30
core/src/main/scala/kafka/security/auth/Acl.scala	42
core/src/main/scala/kafka/security/auth/Authorizer.scala	15
core/src/main/scala/kafka/security/auth/Operation.scala	87
core/src/main/scala/kafka/security/auth/PermissionType.scala	26
core/src/main/scala/kafka/security/auth/Resource.scala	42
core/src/main/scala/kafka/security/auth/ResourceType.scala	64
core/src/main/scala/kafka/security/auth/SimpleAclAuthorizer.scala	121
core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala	440
core/src/main/scala/kafka/security/authorizer/AclEntry.scala	89
core/src/main/scala/kafka/security/authorizer/AuthorizerUtils.scala	38
core/src/main/scala/kafka/security/authorizer/AuthorizerWrapper.scala	137
core/src/main/scala/kafka/serializer/Decoder.scala	29
core/src/main/scala/kafka/server/AbstractFetcherManager.scala	159
core/src/main/scala/kafka/server/AbstractFetcherThread.scala	550
core/src/main/scala/kafka/server/ActionQueue.scala	22
core/src/main/scala/kafka/server/AdminManager.scala	1039
core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala	65
core/src/main/scala/kafka/server/BrokerStates.scala	17
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala	143
core/src/main/scala/kafka/server/ClientQuotaManager.scala	418
core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala	54
core/src/main/scala/kafka/server/ConfigHandler.scala	162
core/src/main/scala/kafka/server/ControllerMutationQuotaManager.scala	150
core/src/main/scala/kafka/server/DelayedCreatePartitions.scala	56
core/src/main/scala/kafka/server/DelayedDeleteRecords.scala	76
core/src/main/scala/kafka/server/DelayedDeleteTopics.scala	40
core/src/main/scala/kafka/server/DelayedElectLeader.scala	38
core/src/main/scala/kafka/server/DelayedFetch.scala	117
core/src/main/scala/kafka/server/DelayedFuture.scala	57
core/src/main/scala/kafka/server/DelayedOperation.scala	208
core/src/main/scala/kafka/server/DelayedOperationKey.scala	25
core/src/main/scala/kafka/server/DelayedProduce.scala	81
core/src/main/scala/kafka/server/DelegationTokenManager.scala	346
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala	715
core/src/main/scala/kafka/server/DynamicConfig.scala	85
core/src/main/scala/kafka/server/DynamicConfigManager.scala	100
core/src/main/scala/kafka/server/FetchDataInfo.scala	11
core/src/main/scala/kafka/server/FetchSession.scala	507
core/src/main/scala/kafka/server/FinalizedFeatureCache.scala	45
core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala	128
core/src/main/scala/kafka/server/KafkaApis.scala	2720
core/src/main/scala/kafka/server/KafkaConfig.scala	1508
core/src/main/scala/kafka/server/KafkaRequestHandler.scala	273
core/src/main/scala/kafka/server/KafkaServer.scala	587
core/src/main/scala/kafka/server/KafkaServerStartable.scala	38
core/src/main/scala/kafka/server/LogDirFailureChannel.scala	14
core/src/main/scala/kafka/server/LogOffsetMetadata.scala	40
core/src/main/scala/kafka/server/MetadataCache.scala	282
core/src/main/scala/kafka/server/QuotaFactory.scala	107
core/src/main/scala/kafka/server/ReplicaAlterLogDirsManager.scala	34
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala	201
core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala	99
core/src/main/scala/kafka/server/ReplicaFetcherManager.scala	26
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala	249
core/src/main/scala/kafka/server/ReplicaManager.scala	1383
core/src/main/scala/kafka/server/ReplicationQuotaManager.scala	99
core/src/main/scala/kafka/server/SensorAccess.scala	24
core/src/main/scala/kafka/server/SupportedFeatures.scala	36
core/src/main/scala/kafka/server/ThrottledChannel.scala	24
core/src/main/scala/kafka/server/checkpoints/CheckpointFile.scala	110
core/src/main/scala/kafka/server/checkpoints/LeaderEpochCheckpointFile.scala	32
core/src/main/scala/kafka/server/checkpoints/OffsetCheckpointFile.scala	52
core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala	141
core/src/main/scala/kafka/tools/ConsoleConsumer.scala	464
core/src/main/scala/kafka/tools/ConsoleProducer.scala	256
core/src/main/scala/kafka/tools/ConsumerPerformance.scala	251
core/src/main/scala/kafka/tools/DumpLogSegments.scala	351
core/src/main/scala/kafka/tools/EndToEndLatency.scala	117
core/src/main/scala/kafka/tools/GetOffsetShell.scala	115
core/src/main/scala/kafka/tools/JmxTool.scala	221
core/src/main/scala/kafka/tools/MirrorMaker.scala	435
core/src/main/scala/kafka/tools/PerfConfig.scala	20
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala	408
core/src/main/scala/kafka/tools/StateChangeLogMerger.scala	129
core/src/main/scala/kafka/tools/StreamsResetter.java	563
core/src/main/scala/kafka/utils/Annotations.scala	5
core/src/main/scala/kafka/utils/CommandDefaultOptions.scala	8
core/src/main/scala/kafka/utils/CommandLineUtils.scala	71
core/src/main/scala/kafka/utils/CoreUtils.scala	180
core/src/main/scala/kafka/utils/DelayedItem.scala	15
core/src/main/scala/kafka/utils/Exit.scala	31
core/src/main/scala/kafka/utils/FileLock.scala	39
core/src/main/scala/kafka/utils/Implicits.scala	12
core/src/main/scala/kafka/utils/Json.scala	27
core/src/main/scala/kafka/utils/KafkaScheduler.scala	80
core/src/main/scala/kafka/utils/Log4jController.scala	68
core/src/main/scala/kafka/utils/Logging.scala	41
core/src/main/scala/kafka/utils/Mx4jLoader.scala	37
core/src/main/scala/kafka/utils/NotNothing.scala	8
core/src/main/scala/kafka/utils/PasswordEncoder.scala	128
core/src/main/scala/kafka/utils/Pool.scala	38
core/src/main/scala/kafka/utils/QuotaUtils.scala	22
core/src/main/scala/kafka/utils/ReplicationUtils.scala	33
core/src/main/scala/kafka/utils/ShutdownableThread.scala	65
core/src/main/scala/kafka/utils/Throttler.scala	65
core/src/main/scala/kafka/utils/ToolsUtils.scala	41
core/src/main/scala/kafka/utils/TopicFilter.scala	25
core/src/main/scala/kafka/utils/VerifiableProperties.scala	118
core/src/main/scala/kafka/utils/VersionInfo.scala	17
core/src/main/scala/kafka/utils/json/DecodeJson.scala	61
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	69
core/src/main/scala/kafka/utils/timer/TimerTask.scala	19
core/src/main/scala/kafka/utils/timer/TimerTaskList.scala	99
core/src/main/scala/kafka/utils/timer/TimingWheel.scala	49
core/src/main/scala/kafka/zk/AdminZkClient.scala	278
core/src/main/scala/kafka/zk/KafkaZkClient.scala	1170
core/src/main/scala/kafka/zk/ZkData.scala	656
core/src/main/scala/kafka/zk/ZkSecurityMigratorUtils.scala	5
core/src/main/scala/kafka/zookeeper/ZooKeeperClient.scala	414
core/src/main/scala/org/apache/zookeeper/ZooKeeperMainWithTlsSupportForKafka.scala	62