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