path	# lines of code
clients/src/main/java/org/apache/kafka/clients/ApiVersions.java	32
clients/src/main/java/org/apache/kafka/clients/ClientRequest.java	63
clients/src/main/java/org/apache/kafka/clients/ClientResponse.java	72
clients/src/main/java/org/apache/kafka/clients/ClientUtils.java	61
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java	143
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java	62
clients/src/main/java/org/apache/kafka/clients/ConnectionState.java	7
clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java	93
clients/src/main/java/org/apache/kafka/clients/KafkaClient.java	28
clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java	47
clients/src/main/java/org/apache/kafka/clients/Metadata.java	214
clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java	15
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java	690
clients/src/main/java/org/apache/kafka/clients/NetworkClientUtils.java	50
clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java	124
clients/src/main/java/org/apache/kafka/clients/RequestCompletionHandler.java	4
clients/src/main/java/org/apache/kafka/clients/admin/AbstractOptions.java	12
clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java	90
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java	127
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java	18
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/Config.java	37
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java	139
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsResult.java	19
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsOptions.java	16
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsResult.java	17
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java	18
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsResult.java	68
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DeletedRecords.java	12
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsResult.java	16
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java	9
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java	27
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsOptions.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsResult.java	35
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java	35
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsResult.java	82
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java	34
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java	1534
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsOptions.java	17
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsResult.java	32
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitions.java	29
clients/src/main/java/org/apache/kafka/clients/admin/NewTopic.java	70
clients/src/main/java/org/apache/kafka/clients/admin/RecordsToDelete.java	31
clients/src/main/java/org/apache/kafka/clients/admin/TopicDescription.java	44
clients/src/main/java/org/apache/kafka/clients/admin/TopicListing.java	19
clients/src/main/java/org/apache/kafka/clients/consumer/CommitFailedException.java	13
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java	45
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java	343
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerInterceptor.java	9
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java	7
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java	113
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java	76
clients/src/main/java/org/apache/kafka/clients/consumer/InvalidOffsetException.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java	693
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java	343
clients/src/main/java/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java	25
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndMetadata.java	44
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndTimestamp.java	33
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetCommitCallback.java	7
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java	19
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java	4
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java	48
clients/src/main/java/org/apache/kafka/clients/consumer/RetriableCommitFailedException.java	20
clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java	45
clients/src/main/java/org/apache/kafka/clients/consumer/StickyAssignor.java	579
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java	711
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java	56
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java	673
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptors.java	47
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetrics.java	27
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java	384
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java	96
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java	1034
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetcherMetricsRegistry.java	133
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java	68
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java	5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoOpConsumerRebalanceListener.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java	59
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java	141
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureAdapter.java	7
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureListener.java	5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StaleMetadataException.java	5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java	329
clients/src/main/java/org/apache/kafka/clients/producer/BufferExhaustedException.java	8
clients/src/main/java/org/apache/kafka/clients/producer/Callback.java	4
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java	612
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java	318
clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java	8
clients/src/main/java/org/apache/kafka/clients/producer/Producer.java	27
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java	281
clients/src/main/java/org/apache/kafka/clients/producer/ProducerInterceptor.java	7
clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java	101
clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java	63
clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java	189
clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java	43
clients/src/main/java/org/apache/kafka/clients/producer/internals/ErrorLoggingCallback.java	33
clients/src/main/java/org/apache/kafka/clients/producer/internals/FutureRecordMetadata.java	80
clients/src/main/java/org/apache/kafka/clients/producer/internals/IncompleteBatches.java	32
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java	50
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java	316
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerIdAndEpoch.java	19
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerInterceptors.java	68
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetrics.java	28
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java	476
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java	629
clients/src/main/java/org/apache/kafka/clients/producer/internals/SenderMetricsRegistry.java	169
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java	986
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java	44
clients/src/main/java/org/apache/kafka/common/Cluster.java	163
clients/src/main/java/org/apache/kafka/common/ClusterResource.java	14
clients/src/main/java/org/apache/kafka/common/ClusterResourceListener.java	4
clients/src/main/java/org/apache/kafka/common/Configurable.java	5
clients/src/main/java/org/apache/kafka/common/KafkaException.java	16
clients/src/main/java/org/apache/kafka/common/KafkaFuture.java	74
clients/src/main/java/org/apache/kafka/common/Metric.java	7
clients/src/main/java/org/apache/kafka/common/MetricName.java	71
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java	56
clients/src/main/java/org/apache/kafka/common/Node.java	83
clients/src/main/java/org/apache/kafka/common/PartitionInfo.java	58
clients/src/main/java/org/apache/kafka/common/Reconfigurable.java	8
clients/src/main/java/org/apache/kafka/common/TopicPartition.java	50
clients/src/main/java/org/apache/kafka/common/TopicPartitionInfo.java	50
clients/src/main/java/org/apache/kafka/common/TopicPartitionReplica.java	61
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntry.java	51
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryData.java	65
clients/src/main/java/org/apache/kafka/common/acl/AccessControlEntryFilter.java	64
clients/src/main/java/org/apache/kafka/common/acl/AclBinding.java	42
clients/src/main/java/org/apache/kafka/common/acl/AclBindingFilter.java	55
clients/src/main/java/org/apache/kafka/common/acl/AclOperation.java	50
clients/src/main/java/org/apache/kafka/common/acl/AclPermissionType.java	41
clients/src/main/java/org/apache/kafka/common/annotation/InterfaceStability.java	16
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java	259
clients/src/main/java/org/apache/kafka/common/config/Config.java	11
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java	801
clients/src/main/java/org/apache/kafka/common/config/ConfigException.java	14
clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java	43
clients/src/main/java/org/apache/kafka/common/config/ConfigValue.java	79
clients/src/main/java/org/apache/kafka/common/config/SaslConfigs.java	50
clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java	86
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java	119
clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java	39
clients/src/main/java/org/apache/kafka/common/config/types/Password.java	26
clients/src/main/java/org/apache/kafka/common/errors/ApiException.java	21
clients/src/main/java/org/apache/kafka/common/errors/AuthenticationException.java	11
clients/src/main/java/org/apache/kafka/common/errors/AuthorizationException.java	9
clients/src/main/java/org/apache/kafka/common/errors/BrokerNotAvailableException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ClusterAuthorizationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ConcurrentTransactionsException.java	7
clients/src/main/java/org/apache/kafka/common/errors/ControllerMovedException.java	10
clients/src/main/java/org/apache/kafka/common/errors/CoordinatorLoadInProgressException.java	10
clients/src/main/java/org/apache/kafka/common/errors/CoordinatorNotAvailableException.java	14
clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java	16
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenAuthorizationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenDisabledException.java	10
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenExpiredException.java	10
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenNotFoundException.java	10
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenOwnerMismatchException.java	10
clients/src/main/java/org/apache/kafka/common/errors/DisconnectException.java	17
clients/src/main/java/org/apache/kafka/common/errors/DuplicateSequenceException.java	6
clients/src/main/java/org/apache/kafka/common/errors/GroupAuthorizationException.java	11
clients/src/main/java/org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.java	18
clients/src/main/java/org/apache/kafka/common/errors/GroupIdNotFoundException.java	11
clients/src/main/java/org/apache/kafka/common/errors/GroupLoadInProgressException.java	17
clients/src/main/java/org/apache/kafka/common/errors/GroupNotEmptyException.java	11
clients/src/main/java/org/apache/kafka/common/errors/IllegalGenerationException.java	16
clients/src/main/java/org/apache/kafka/common/errors/IllegalSaslStateException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InconsistentGroupProtocolException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InterruptException.java	17
clients/src/main/java/org/apache/kafka/common/errors/InvalidCommitOffsetSizeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidConfigurationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidFetchSizeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidGroupIdException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidMetadataException.java	16
clients/src/main/java/org/apache/kafka/common/errors/InvalidOffsetException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidPartitionsException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidPidMappingException.java	6
clients/src/main/java/org/apache/kafka/common/errors/InvalidPrincipalTypeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidReplicaAssignmentException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidReplicationFactorException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequestException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequiredAcksException.java	7
clients/src/main/java/org/apache/kafka/common/errors/InvalidSessionTimeoutException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidTimestampException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidTopicException.java	16
clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnStateException.java	6
clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnTimeoutException.java	10
clients/src/main/java/org/apache/kafka/common/errors/KafkaStorageException.java	16
clients/src/main/java/org/apache/kafka/common/errors/LeaderNotAvailableException.java	10
clients/src/main/java/org/apache/kafka/common/errors/LogDirNotFoundException.java	13
clients/src/main/java/org/apache/kafka/common/errors/NetworkException.java	16
clients/src/main/java/org/apache/kafka/common/errors/NotControllerException.java	10
clients/src/main/java/org/apache/kafka/common/errors/NotCoordinatorException.java	10
clients/src/main/java/org/apache/kafka/common/errors/NotCoordinatorForGroupException.java	17
clients/src/main/java/org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.java	7
clients/src/main/java/org/apache/kafka/common/errors/NotEnoughReplicasException.java	16
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderForPartitionException.java	16
clients/src/main/java/org/apache/kafka/common/errors/OffsetMetadataTooLarge.java	15
clients/src/main/java/org/apache/kafka/common/errors/OffsetOutOfRangeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/OperationNotAttemptedException.java	6
clients/src/main/java/org/apache/kafka/common/errors/OutOfOrderSequenceException.java	6
clients/src/main/java/org/apache/kafka/common/errors/PolicyViolationException.java	9
clients/src/main/java/org/apache/kafka/common/errors/ProducerFencedException.java	6
clients/src/main/java/org/apache/kafka/common/errors/ReassignmentInProgressException.java	9
clients/src/main/java/org/apache/kafka/common/errors/RebalanceInProgressException.java	16
clients/src/main/java/org/apache/kafka/common/errors/RecordBatchTooLargeException.java	16
clients/src/main/java/org/apache/kafka/common/errors/RecordTooLargeException.java	26
clients/src/main/java/org/apache/kafka/common/errors/ReplicaNotAvailableException.java	13
clients/src/main/java/org/apache/kafka/common/errors/RetriableException.java	15
clients/src/main/java/org/apache/kafka/common/errors/SaslAuthenticationException.java	11
clients/src/main/java/org/apache/kafka/common/errors/SecurityDisabledException.java	10
clients/src/main/java/org/apache/kafka/common/errors/SerializationException.java	21
clients/src/main/java/org/apache/kafka/common/errors/SslAuthenticationException.java	11
clients/src/main/java/org/apache/kafka/common/errors/TimeoutException.java	16
clients/src/main/java/org/apache/kafka/common/errors/TopicAuthorizationException.java	16
clients/src/main/java/org/apache/kafka/common/errors/TopicExistsException.java	10
clients/src/main/java/org/apache/kafka/common/errors/TransactionCoordinatorFencedException.java	10
clients/src/main/java/org/apache/kafka/common/errors/TransactionalIdAuthorizationException.java	6
clients/src/main/java/org/apache/kafka/common/errors/UnknownMemberIdException.java	16
clients/src/main/java/org/apache/kafka/common/errors/UnknownProducerIdException.java	6
clients/src/main/java/org/apache/kafka/common/errors/UnknownServerException.java	15
clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java	15
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedByAuthenticationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedForMessageFormatException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedSaslMechanismException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedVersionException.java	11
clients/src/main/java/org/apache/kafka/common/errors/WakeupException.java	5
clients/src/main/java/org/apache/kafka/common/header/Header.java	5
clients/src/main/java/org/apache/kafka/common/header/Headers.java	9
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeader.java	51
clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java	158
clients/src/main/java/org/apache/kafka/common/internals/ClusterResourceListeners.java	26
clients/src/main/java/org/apache/kafka/common/internals/FatalExitError.java	17
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java	211
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java	104
clients/src/main/java/org/apache/kafka/common/internals/Topic.java	44
clients/src/main/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPool.java	110
clients/src/main/java/org/apache/kafka/common/memory/MemoryPool.java	34
clients/src/main/java/org/apache/kafka/common/memory/SimpleMemoryPool.java	92
clients/src/main/java/org/apache/kafka/common/metrics/CompoundStat.java	21
clients/src/main/java/org/apache/kafka/common/metrics/Gauge.java	4
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java	197
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java	64
clients/src/main/java/org/apache/kafka/common/metrics/Measurable.java	4
clients/src/main/java/org/apache/kafka/common/metrics/MeasurableStat.java	3
clients/src/main/java/org/apache/kafka/common/metrics/MetricConfig.java	65
clients/src/main/java/org/apache/kafka/common/metrics/MetricValueProvider.java	2
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java	309
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java	9
clients/src/main/java/org/apache/kafka/common/metrics/Quota.java	45
clients/src/main/java/org/apache/kafka/common/metrics/QuotaViolationException.java	28
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java	166
clients/src/main/java/org/apache/kafka/common/metrics/Stat.java	4
clients/src/main/java/org/apache/kafka/common/metrics/stats/Avg.java	22
clients/src/main/java/org/apache/kafka/common/metrics/stats/Count.java	19
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequencies.java	112
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequency.java	16
clients/src/main/java/org/apache/kafka/common/metrics/stats/Histogram.java	132
clients/src/main/java/org/apache/kafka/common/metrics/stats/Max.java	19
clients/src/main/java/org/apache/kafka/common/metrics/stats/Meter.java	40
clients/src/main/java/org/apache/kafka/common/metrics/stats/Min.java	19
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentile.java	17
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentiles.java	92
clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java	80
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java	87
clients/src/main/java/org/apache/kafka/common/metrics/stats/SimpleRate.java	10
clients/src/main/java/org/apache/kafka/common/metrics/stats/Sum.java	19
clients/src/main/java/org/apache/kafka/common/metrics/stats/Total.java	20
clients/src/main/java/org/apache/kafka/common/metrics/stats/Value.java	14
clients/src/main/java/org/apache/kafka/common/network/Authenticator.java	10
clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java	40
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilder.java	10
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java	125
clients/src/main/java/org/apache/kafka/common/network/ChannelState.java	34
clients/src/main/java/org/apache/kafka/common/network/InvalidReceiveException.java	10
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java	176
clients/src/main/java/org/apache/kafka/common/network/ListenerName.java	39
clients/src/main/java/org/apache/kafka/common/network/ListenerReconfigurable.java	5
clients/src/main/java/org/apache/kafka/common/network/Mode.java	2
clients/src/main/java/org/apache/kafka/common/network/MultiSend.java	63
clients/src/main/java/org/apache/kafka/common/network/NetworkReceive.java	115
clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java	16
clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java	59
clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java	107
clients/src/main/java/org/apache/kafka/common/network/Receive.java	11
clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java	180
clients/src/main/java/org/apache/kafka/common/network/Selectable.java	23
clients/src/main/java/org/apache/kafka/common/network/Selector.java	739
clients/src/main/java/org/apache/kafka/common/network/Send.java	9
clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java	104
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java	546
clients/src/main/java/org/apache/kafka/common/network/TransportLayer.java	25
clients/src/main/java/org/apache/kafka/common/network/TransportLayers.java	10
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java	300
clients/src/main/java/org/apache/kafka/common/protocol/CommonFields.java	31
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java	678
clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java	144
clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java	76
clients/src/main/java/org/apache/kafka/common/protocol/types/BoundField.java	15
clients/src/main/java/org/apache/kafka/common/protocol/types/Field.java	62
clients/src/main/java/org/apache/kafka/common/protocol/types/Schema.java	123
clients/src/main/java/org/apache/kafka/common/protocol/types/SchemaException.java	8
clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java	293
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java	424
clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java	450
clients/src/main/java/org/apache/kafka/common/record/AbstractRecordBatch.java	15
clients/src/main/java/org/apache/kafka/common/record/AbstractRecords.java	168
clients/src/main/java/org/apache/kafka/common/record/BufferSupplier.java	49
clients/src/main/java/org/apache/kafka/common/record/ByteBufferLogInputStream.java	38
clients/src/main/java/org/apache/kafka/common/record/CompressionRatioEstimator.java	58
clients/src/main/java/org/apache/kafka/common/record/CompressionType.java	128
clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java	57
clients/src/main/java/org/apache/kafka/common/record/ConvertedRecords.java	15
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java	363
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java	483
clients/src/main/java/org/apache/kafka/common/record/EndTransactionMarker.java	82
clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java	178
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java	303
clients/src/main/java/org/apache/kafka/common/record/InvalidRecordException.java	11
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/record/LegacyRecord.java	337
clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java	5
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java	468
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java	455
clients/src/main/java/org/apache/kafka/common/record/MutableRecordBatch.java	8
clients/src/main/java/org/apache/kafka/common/record/Record.java	23
clients/src/main/java/org/apache/kafka/common/record/RecordBatch.java	38
clients/src/main/java/org/apache/kafka/common/record/RecordBatchIterator.java	21
clients/src/main/java/org/apache/kafka/common/record/Records.java	21
clients/src/main/java/org/apache/kafka/common/record/RecordsProcessingStats.java	26
clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java	79
clients/src/main/java/org/apache/kafka/common/record/TimestampType.java	21
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java	164
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java	12
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java	136
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnRequest.java	97
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java	54
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java	134
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java	93
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsRequest.java	152
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java	80
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequest.java	121
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java	88
clients/src/main/java/org/apache/kafka/common/requests/ApiError.java	56
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsRequest.java	64
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java	145
clients/src/main/java/org/apache/kafka/common/requests/BasePartitionState.java	18
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownRequest.java	72
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownResponse.java	75
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java	115
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java	83
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenRequest.java	100
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java	129
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsRequest.java	172
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsResponse.java	77
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java	263
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java	83
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java	100
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java	158
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsRequest.java	80
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java	81
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java	127
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java	118
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsRequest.java	96
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsResponse.java	78
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsRequest.java	79
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java	114
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsRequest.java	133
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java	283
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenRequest.java	91
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java	139
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsRequest.java	73
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java	221
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsRequest.java	114
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java	170
clients/src/main/java/org/apache/kafka/common/requests/EndTxnRequest.java	99
clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java	54
clients/src/main/java/org/apache/kafka/common/requests/EpochEndOffset.java	47
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenRequest.java	74
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java	61
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java	300
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java	345
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorRequest.java	126
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java	97
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java	92
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java	52
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRequest.java	76
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java	78
clients/src/main/java/org/apache/kafka/common/requests/IsolationLevel.java	21
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java	212
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java	157
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java	241
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java	79
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java	80
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupResponse.java	52
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsRequest.java	53
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java	99
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java	281
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java	180
clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java	148
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java	402
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java	264
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java	97
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java	168
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java	155
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java	118
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java	91
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java	289
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java	179
clients/src/main/java/org/apache/kafka/common/requests/RecordsSend.java	46
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenRequest.java	74
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java	61
clients/src/main/java/org/apache/kafka/common/requests/RequestAndSize.java	9
clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java	64
clients/src/main/java/org/apache/kafka/common/requests/RequestHeader.java	118
clients/src/main/java/org/apache/kafka/common/requests/RequestUtils.java	67
clients/src/main/java/org/apache/kafka/common/requests/Resource.java	34
clients/src/main/java/org/apache/kafka/common/requests/ResourceType.java	19
clients/src/main/java/org/apache/kafka/common/requests/ResponseHeader.java	33
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateRequest.java	68
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateResponse.java	62
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeRequest.java	75
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeResponse.java	58
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaRequest.java	139
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaResponse.java	78
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupRequest.java	137
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java	64
clients/src/main/java/org/apache/kafka/common/requests/TransactionResult.java	14
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java	191
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java	99
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataRequest.java	373
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataResponse.java	42
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersRequest.java	197
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java	111
clients/src/main/java/org/apache/kafka/common/resource/Resource.java	43
clients/src/main/java/org/apache/kafka/common/resource/ResourceFilter.java	57
clients/src/main/java/org/apache/kafka/common/resource/ResourceType.java	44
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java	81
clients/src/main/java/org/apache/kafka/common/security/JaasContext.java	125
clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java	31
clients/src/main/java/org/apache/kafka/common/security/auth/AuthenticationContext.java	6
clients/src/main/java/org/apache/kafka/common/security/auth/DefaultPrincipalBuilder.java	18
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipal.java	52
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipalBuilder.java	4
clients/src/main/java/org/apache/kafka/common/security/auth/PlaintextAuthenticationContext.java	16
clients/src/main/java/org/apache/kafka/common/security/auth/PrincipalBuilder.java	15
clients/src/main/java/org/apache/kafka/common/security/auth/SaslAuthenticationContext.java	24
clients/src/main/java/org/apache/kafka/common/security/auth/SecurityProtocol.java	41
clients/src/main/java/org/apache/kafka/common/security/auth/SslAuthenticationContext.java	22
clients/src/main/java/org/apache/kafka/common/security/authenticator/AbstractLogin.java	57
clients/src/main/java/org/apache/kafka/common/security/authenticator/AuthCallbackHandler.java	9
clients/src/main/java/org/apache/kafka/common/security/authenticator/CredentialCache.java	42
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultKafkaPrincipalBuilder.java	100
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultLogin.java	10
clients/src/main/java/org/apache/kafka/common/security/authenticator/Login.java	13
clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java	90
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java	353
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientCallbackHandler.java	68
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java	399
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerCallbackHandler.java	50
clients/src/main/java/org/apache/kafka/common/security/kerberos/BadFormatString.java	10
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java	285
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosName.java	51
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosRule.java	133
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosShortNamer.java	62
clients/src/main/java/org/apache/kafka/common/security/kerberos/NoMatchingRule.java	7
clients/src/main/java/org/apache/kafka/common/security/plain/PlainLoginModule.java	38
clients/src/main/java/org/apache/kafka/common/security/plain/PlainSaslServer.java	107
clients/src/main/java/org/apache/kafka/common/security/plain/PlainSaslServerProvider.java	15
clients/src/main/java/org/apache/kafka/common/security/scram/DelegationTokenAuthenticationCallback.java	11
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredential.java	25
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredentialCallback.java	30
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredentialUtils.java	52
clients/src/main/java/org/apache/kafka/common/security/scram/ScramFormatter.java	121
clients/src/main/java/org/apache/kafka/common/security/scram/ScramLoginModule.java	42
clients/src/main/java/org/apache/kafka/common/security/scram/ScramMechanism.java	47
clients/src/main/java/org/apache/kafka/common/security/scram/ScramMessages.java	227
clients/src/main/java/org/apache/kafka/common/security/scram/ScramSaslClient.java	186
clients/src/main/java/org/apache/kafka/common/security/scram/ScramSaslClientProvider.java	16
clients/src/main/java/org/apache/kafka/common/security/scram/ScramSaslServer.java	184
clients/src/main/java/org/apache/kafka/common/security/scram/ScramSaslServerProvider.java	16
clients/src/main/java/org/apache/kafka/common/security/scram/ScramServerCallbackHandler.java	43
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java	379
clients/src/main/java/org/apache/kafka/common/security/token/delegation/DelegationToken.java	51
clients/src/main/java/org/apache/kafka/common/security/token/delegation/DelegationTokenCache.java	71
clients/src/main/java/org/apache/kafka/common/security/token/delegation/TokenInformation.java	100
clients/src/main/java/org/apache/kafka/common/serialization/ByteArrayDeserializer.java	14
clients/src/main/java/org/apache/kafka/common/serialization/ByteArraySerializer.java	14
clients/src/main/java/org/apache/kafka/common/serialization/ByteBufferDeserializer.java	14
clients/src/main/java/org/apache/kafka/common/serialization/ByteBufferSerializer.java	24
clients/src/main/java/org/apache/kafka/common/serialization/BytesDeserializer.java	14
clients/src/main/java/org/apache/kafka/common/serialization/BytesSerializer.java	14
clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java	9
clients/src/main/java/org/apache/kafka/common/serialization/DoubleDeserializer.java	25
clients/src/main/java/org/apache/kafka/common/serialization/DoubleSerializer.java	26
clients/src/main/java/org/apache/kafka/common/serialization/ExtendedDeserializer.java	31
clients/src/main/java/org/apache/kafka/common/serialization/ExtendedSerializer.java	31
clients/src/main/java/org/apache/kafka/common/serialization/FloatDeserializer.java	25
clients/src/main/java/org/apache/kafka/common/serialization/FloatSerializer.java	22
clients/src/main/java/org/apache/kafka/common/serialization/IntegerDeserializer.java	22
clients/src/main/java/org/apache/kafka/common/serialization/IntegerSerializer.java	18
clients/src/main/java/org/apache/kafka/common/serialization/LongDeserializer.java	22
clients/src/main/java/org/apache/kafka/common/serialization/LongSerializer.java	22
clients/src/main/java/org/apache/kafka/common/serialization/Serde.java	10
clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java	145
clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java	9
clients/src/main/java/org/apache/kafka/common/serialization/ShortDeserializer.java	22
clients/src/main/java/org/apache/kafka/common/serialization/ShortSerializer.java	16
clients/src/main/java/org/apache/kafka/common/serialization/StringDeserializer.java	30
clients/src/main/java/org/apache/kafka/common/serialization/StringSerializer.java	30
clients/src/main/java/org/apache/kafka/common/utils/AbstractIterator.java	56
clients/src/main/java/org/apache/kafka/common/utils/AppInfoParser.java	98
clients/src/main/java/org/apache/kafka/common/utils/Base64.java	231
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java	23
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferOutputStream.java	65
clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java	158
clients/src/main/java/org/apache/kafka/common/utils/Bytes.java	97
clients/src/main/java/org/apache/kafka/common/utils/Checksums.java	35
clients/src/main/java/org/apache/kafka/common/utils/CircularIterator.java	30
clients/src/main/java/org/apache/kafka/common/utils/CloseableIterator.java	6
clients/src/main/java/org/apache/kafka/common/utils/CollectionUtils.java	36
clients/src/main/java/org/apache/kafka/common/utils/CopyOnWriteMap.java	105
clients/src/main/java/org/apache/kafka/common/utils/Crc32.java	313
clients/src/main/java/org/apache/kafka/common/utils/Crc32C.java	57
clients/src/main/java/org/apache/kafka/common/utils/Exit.java	44
clients/src/main/java/org/apache/kafka/common/utils/Java.java	40
clients/src/main/java/org/apache/kafka/common/utils/KafkaThread.java	28
clients/src/main/java/org/apache/kafka/common/utils/LogContext.java	631
clients/src/main/java/org/apache/kafka/common/utils/MappedByteBuffers.java	87
clients/src/main/java/org/apache/kafka/common/utils/OperatingSystem.java	12
clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java	581
clients/src/main/java/org/apache/kafka/common/utils/Sanitizer.java	41
clients/src/main/java/org/apache/kafka/common/utils/Scheduler.java	10
clients/src/main/java/org/apache/kafka/common/utils/SecurityUtils.java	14
clients/src/main/java/org/apache/kafka/common/utils/Shell.java	168
clients/src/main/java/org/apache/kafka/common/utils/SystemScheduler.java	18
clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java	24
clients/src/main/java/org/apache/kafka/common/utils/Time.java	8
clients/src/main/java/org/apache/kafka/common/utils/Utils.java	493
clients/src/main/java/org/apache/kafka/server/policy/AlterConfigPolicy.java	27
clients/src/main/java/org/apache/kafka/server/policy/CreateTopicPolicy.java	47
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
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkConnector.java	47
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkTask.java	64
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java	67
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java	187
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java	641
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java	39
connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java	29
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSchema.java	58
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java	27
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
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java	339
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java	75
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java	208
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java	85
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java	209
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java	127
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/RegexRouter.java	46
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java	170
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java	96
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java	348
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java	64
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ValueToKey.java	74
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidator.java	16
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/RegexValidator.java	18
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/Requirements.java	48
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java	19
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SimpleConfig.java	9
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
doap_Kafka.rdf	34
gradle/resources/rat-output-to-html.xsl	153
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/TopicBenchmark.java	31
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRecordBenchmark.java	25
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java	104
kafka-merge-pr.py	306
log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java	212
release.py	275
release_notes.py	64
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java	45
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java	36
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java	59
streams/src/main/java/org/apache/kafka/streams/Consumed.java	56
streams/src/main/java/org/apache/kafka/streams/KafkaClientSupplier.java	12
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java	577
streams/src/main/java/org/apache/kafka/streams/KeyValue.java	32
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java	166
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java	584
streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java	31
streams/src/main/java/org/apache/kafka/streams/Topology.java	194
streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java	30
streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java	13
streams/src/main/java/org/apache/kafka/streams/errors/DeserializationExceptionHandler.java	19
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/LockException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java	23
streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java	23
streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/ProductionExceptionHandler.java	18
streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java	14
streams/src/main/java/org/apache/kafka/streams/errors/TaskAssignmentException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/TaskMigratedException.java	24
streams/src/main/java/org/apache/kafka/streams/errors/TopologyBuilderException.java	14
streams/src/main/java/org/apache/kafka/streams/errors/TopologyException.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java	10
streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java	60
streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java	49
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java	123
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java	58
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java	193
streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java	306
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java	191
streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Materialized.java	85
streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Printed.java	49
streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java	53
streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Serialized.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java	42
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java	21
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java	69
streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java	56
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapperWithKey.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java	15
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java	12
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/Window.java	48
streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java	33
streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java	32
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java	150
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CacheFlushListener.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/Change.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedDeserializer.java	41
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java	50
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ConsumedInternal.java	31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ForwardingCacheFlushListener.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GlobalKTableImpl.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java	63
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalNameProvider.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java	161
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalValueTransformerWithKey.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalValueTransformerWithKeySupplier.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java	441
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java	234
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggProcessorSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java	75
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamBranch.java	27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFilter.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMap.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValues.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoin.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java	769
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamJoinWindow.java	36
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java	53
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoin.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java	35
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMap.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMapValues.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPassThrough.java	16
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPeek.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPrint.java	27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java	73
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java	122
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransform.java	46
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java	137
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java	108
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowReduce.java	106
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java	64
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java	95
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java	710
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoinValueGetterSupplier.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java	91
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java	76
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java	78
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinValueGetter.java	34
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java	78
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java	89
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMaterializedValueGetterSupplier.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableProcessorSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java	60
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java	65
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSourceValueGetterSupplier.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetter.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetterSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KeyValueStoreMaterializer.java	31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.java	47
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintForeachAction.java	30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintedInternal.java	12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ProducedInternal.java	18
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SerializedInternal.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionKeySerde.java	116
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindow.java	17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java	172
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindow.java	21
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java	152
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TupleForwarder.java	42
streams/src/main/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindow.java	17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedDeserializer.java	63
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedSerializer.java	50
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedStreamPartitioner.java	17
streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingBatchingRestoreCallback.java	26
streams/src/main/java/org/apache/kafka/streams/processor/AbstractNotifyingRestoreCallback.java	21
streams/src/main/java/org/apache/kafka/streams/processor/AbstractProcessor.java	20
streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java	6
streams/src/main/java/org/apache/kafka/streams/processor/Cancellable.java	4
streams/src/main/java/org/apache/kafka/streams/processor/DefaultPartitionGrouper.java	51
streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java	17
streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java	22
streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java	16
streams/src/main/java/org/apache/kafka/streams/processor/PartitionGrouper.java	8
streams/src/main/java/org/apache/kafka/streams/processor/Processor.java	10
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java	31
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/processor/PunctuationType.java	5
streams/src/main/java/org/apache/kafka/streams/processor/Punctuator.java	4
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java	6
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreListener.java	15
streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java	10
streams/src/main/java/org/apache/kafka/streams/processor/StateStoreSupplier.java	9
streams/src/main/java/org/apache/kafka/streams/processor/StreamPartitioner.java	5
streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java	67
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java	44
streams/src/main/java/org/apache/kafka/streams/processor/ThreadMetadata.java	59
streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java	8
streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java	391
streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java	18
streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java	10
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java	159
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/AssignedStandbyTasks.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasks.java	98
streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java	385
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java	10
streams/src/main/java/org/apache/kafka/streams/processor/internals/Checkpointable.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListener.java	72
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultKafkaClientSupplier.java	28
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamPartitioner.java	22
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java	41
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java	11
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManager.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java	297
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java	77
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java	243
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java	12
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java	38
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java	180
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java	1507
streams/src/main/java/org/apache/kafka/streams/processor/internals/MinTimestampTracker.java	40
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java	99
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java	93
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java	150
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java	6
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java	45
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java	263
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java	152
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationQueue.java	36
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationSchedule.java	61
streams/src/main/java/org/apache/kafka/streams/processor/internals/QuickUnion.java	37
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java	28
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java	201
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordContext.java	8
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java	61
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java	101
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java	45
streams/src/main/java/org/apache/kafka/streams/processor/internals/RestoringTasks.java	5
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java	79
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java	68
streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java	16
streams/src/main/java/org/apache/kafka/streams/processor/internals/StampedRecord.java	26
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyContextImpl.java	124
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java	89
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java	241
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java	19
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestorer.java	81
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java	246
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java	523
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java	418
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java	836
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java	183
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetricsImpl.java	151
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java	29
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskAction.java	5
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java	325
streams/src/main/java/org/apache/kafka/streams/processor/internals/ThreadStateTransitionValidator.java	4
streams/src/main/java/org/apache/kafka/streams/processor/internals/TimestampTracker.java	9
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java	42
streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.java	53
streams/src/main/java/org/apache/kafka/streams/processor/internals/WrappedBatchingStateRestoreCallback.java	22
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java	137
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java	112
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.java	247
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java	109
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignor.java	4
streams/src/main/java/org/apache/kafka/streams/state/HostInfo.java	44
streams/src/main/java/org/apache/kafka/streams/state/KeyValueBytesStoreSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/state/KeyValueIterator.java	9
streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java	10
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java	7
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java	58
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java	8
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java	6
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java	9
streams/src/main/java/org/apache/kafka/streams/state/RocksDBConfigSetter.java	6
streams/src/main/java/org/apache/kafka/streams/state/SessionBytesStoreSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java	9
streams/src/main/java/org/apache/kafka/streams/state/StateSerdes.java	60
streams/src/main/java/org/apache/kafka/streams/state/StoreBuilder.java	12
streams/src/main/java/org/apache/kafka/streams/state/StoreSupplier.java	7
streams/src/main/java/org/apache/kafka/streams/state/Stores.java	288
streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java	61
streams/src/main/java/org/apache/kafka/streams/state/WindowBytesStoreSupplier.java	8
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java	6
streams/src/main/java/org/apache/kafka/streams/state/WindowStoreIterator.java	7
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterator.java	104
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractStoreBuilder.java	58
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractStoreSupplier.java	36
streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFunction.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/CachedStateStore.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java	232
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java	168
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java	195
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java	70
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java	59
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java	65
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeKeyValueIterator.java	46
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java	79
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStore.java	55
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java	82
streams/src/main/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIterator.java	61
streams/src/main/java/org/apache/kafka/streams/state/internals/FilteredCacheIterator.java	76
streams/src/main/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProvider.java	25
streams/src/main/java/org/apache/kafka/streams/state/internals/HasNextCondition.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueLoggedStore.java	86
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java	137
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStoreSupplier.java	18
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryLRUCacheStoreSupplier.java	20
streams/src/main/java/org/apache/kafka/streams/state/internals/InnerMeteredKeyValueStore.java	256
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueIterators.java	40
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java	38
streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java	55
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java	134
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java	58
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreIterator.java	30
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheSessionStoreIterator.java	40
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIterator.java	35
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreKeyValueIterator.java	48
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueBytesStore.java	105
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java	84
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java	139
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java	117
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java	52
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java	58
streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java	317
streams/src/main/java/org/apache/kafka/streams/state/internals/NextIteratorFunction.java	5
streams/src/main/java/org/apache/kafka/streams/state/internals/OffsetCheckpoint.java	111
streams/src/main/java/org/apache/kafka/streams/state/internals/OrderedBytes.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/PeekingKeyValueIterator.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBKeyValueStoreSupplier.java	28
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java	114
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java	87
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStoreSupplier.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java	448
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java	100
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreSupplier.java	42
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.java	25
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbSessionBytesStoreSupplier.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java	62
streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java	27
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java	65
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java	25
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedCacheFunction.java	47
streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java	197
streams/src/main/java/org/apache/kafka/streams/state/internals/SerializedKeyValueIterator.java	43
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java	68
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilder.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/StateStoreProvider.java	8
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreChangeLogger.java	30
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java	38
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java	250
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java	65
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java	43
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java	149
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreUtils.java	47
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java	57
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java	54
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java	24
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java	345
tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java	450
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java	344
tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java	257
tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java	67
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java	36
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java	256
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java	496
tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java	188
tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java	364
tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java	106
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java	131
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentRestResource.java	55
tools/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java	403
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicNode.java	83
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicPlatform.java	82
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicTopology.java	34
tools/src/main/java/org/apache/kafka/trogdor/common/JsonUtil.java	27
tools/src/main/java/org/apache/kafka/trogdor/common/Node.java	24
tools/src/main/java/org/apache/kafka/trogdor/common/Platform.java	33
tools/src/main/java/org/apache/kafka/trogdor/common/ThreadUtils.java	23
tools/src/main/java/org/apache/kafka/trogdor/common/Topology.java	20
tools/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java	88
tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java	110
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java	142
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorRestResource.java	62
tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java	201
tools/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java	351
tools/src/main/java/org/apache/kafka/trogdor/fault/FilesUnreadableFaultSpec.java	52
tools/src/main/java/org/apache/kafka/trogdor/fault/Kibosh.java	144
tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultController.java	14
tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultWorker.java	30
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultController.java	20
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultSpec.java	47
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultWorker.java	53
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultController.java	14
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultSpec.java	38
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultWorker.java	55
tools/src/main/java/org/apache/kafka/trogdor/rest/AgentStatusResponse.java	22
tools/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorShutdownRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorStatusResponse.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateTaskRequest.java	22
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateTaskResponse.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateWorkerRequest.java	22
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateWorkerResponse.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/Empty.java	23
tools/src/main/java/org/apache/kafka/trogdor/rest/ErrorResponse.java	39
tools/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java	187
tools/src/main/java/org/apache/kafka/trogdor/rest/Message.java	19
tools/src/main/java/org/apache/kafka/trogdor/rest/RestExceptionMapper.java	49
tools/src/main/java/org/apache/kafka/trogdor/rest/StopTaskRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/StopTaskResponse.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/StopWorkerRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/StopWorkerResponse.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskDone.java	38
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskPending.java	10
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRunning.java	17
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskState.java	24
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStopping.java	17
tools/src/main/java/org/apache/kafka/trogdor/rest/TasksResponse.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerDone.java	44
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerReceiving.java	10
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerRunning.java	30
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStarting.java	10
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerState.java	41
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStopping.java	34
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskController.java	14
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskSpec.java	18
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskWorker.java	22
tools/src/main/java/org/apache/kafka/trogdor/task/TaskController.java	6
tools/src/main/java/org/apache/kafka/trogdor/task/TaskSpec.java	42
tools/src/main/java/org/apache/kafka/trogdor/task/TaskWorker.java	9
tools/src/main/java/org/apache/kafka/trogdor/workload/Histogram.java	127
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java	79
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java	248
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java	286
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java	66
tools/src/main/java/org/apache/kafka/trogdor/workload/Throttle.java	41