path	# lines of code
clients/src/main/java/org/apache/kafka/clients/RequestCompletionHandler.java	4
clients/src/main/java/org/apache/kafka/clients/producer/UniformStickyPartitioner.java	15
clients/src/main/java/org/apache/kafka/clients/producer/BufferExhaustedException.java	8
clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java	57
clients/src/main/java/org/apache/kafka/clients/producer/ProducerInterceptor.java	7
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java	374
clients/src/main/java/org/apache/kafka/clients/producer/RoundRobinPartitioner.java	33
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java	1333
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java	50
clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java	23
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java	319
clients/src/main/java/org/apache/kafka/clients/producer/internals/SenderMetricsRegistry.java	171
clients/src/main/java/org/apache/kafka/clients/producer/internals/IncompleteBatches.java	32
clients/src/main/java/org/apache/kafka/clients/producer/internals/StickyPartitionCache.java	47
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetrics.java	27
clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java	216
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java	657
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetadata.java	109
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java	516
clients/src/main/java/org/apache/kafka/clients/producer/internals/FutureRecordMetadata.java	84
clients/src/main/java/org/apache/kafka/clients/producer/internals/ErrorLoggingCallback.java	33
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerInterceptors.java	68
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionalRequestResult.java	59
clients/src/main/java/org/apache/kafka/clients/producer/Callback.java	4
clients/src/main/java/org/apache/kafka/clients/producer/Producer.java	35
clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java	95
clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java	10
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java	692
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java	418
clients/src/main/java/org/apache/kafka/clients/GroupRebalanceConfig.java	64
clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java	97
clients/src/main/java/org/apache/kafka/clients/ClientUtils.java	97
clients/src/main/java/org/apache/kafka/clients/ApiVersion.java	29
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java	137
clients/src/main/java/org/apache/kafka/clients/ClientRequest.java	85
clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java	138
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/PartitionReassignment.java	30
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersResult.java	40
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClientQuotasOptions.java	5
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenOptions.java	13
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsResult.java	82
clients/src/main/java/org/apache/kafka/clients/admin/DescribeDelegationTokenResult.java	15
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java	26
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java	3377
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java	17
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java	92
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult.java	16
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsOptions.java	24
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenOptions.java	13
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsOptions.java	26
clients/src/main/java/org/apache/kafka/clients/admin/MemberToRemove.java	31
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java	222
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/TopicDescription.java	55
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterResult.java	35
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsResult.java	13
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptions.java	25
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult.java	59
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsResult.java	64
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialAlteration.java	11
clients/src/main/java/org/apache/kafka/clients/admin/ScramCredentialInfo.java	35
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsResult.java	16
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsOptions.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java	68
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialUpsertion.java	34
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java	83
clients/src/main/java/org/apache/kafka/clients/admin/ExpireDelegationTokenResult.java	13
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsOptions.java	14
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/NewTopic.java	102
clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsResult.java	17
clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialDeletion.java	12
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialsDescription.java	38
clients/src/main/java/org/apache/kafka/clients/admin/ScramMechanism.java	30
clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsOptions.java	10
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersOptions.java	9
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult.java	59
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsResult.java	64
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitionReassignment.java	16
clients/src/main/java/org/apache/kafka/clients/admin/OffsetSpec.java	24
clients/src/main/java/org/apache/kafka/clients/admin/TopicListing.java	19
clients/src/main/java/org/apache/kafka/clients/admin/MemberAssignment.java	32
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java	15
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java	151
clients/src/main/java/org/apache/kafka/clients/admin/internals/MetadataOperationContext.java	59
clients/src/main/java/org/apache/kafka/clients/admin/internals/ConsumerGroupOperationContext.java	50
clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java	11
clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenResult.java	14
clients/src/main/java/org/apache/kafka/clients/admin/DeletedRecords.java	12
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsResult.java	22
clients/src/main/java/org/apache/kafka/clients/admin/ElectLeadersOptions.java	7
clients/src/main/java/org/apache/kafka/clients/admin/ReplicaInfo.java	28
clients/src/main/java/org/apache/kafka/clients/admin/RenewDelegationTokenResult.java	13
clients/src/main/java/org/apache/kafka/clients/admin/RecordsToDelete.java	31
clients/src/main/java/org/apache/kafka/clients/admin/ListOffsetsOptions.java	17
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java	18
clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsResult.java	20
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java	77
clients/src/main/java/org/apache/kafka/clients/admin/ListPartitionReassignmentsOptions.java	5
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java	67
clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java	18
clients/src/main/java/org/apache/kafka/clients/admin/Config.java	38
clients/src/main/java/org/apache/kafka/clients/admin/ElectPreferredLeadersResult.java	61
clients/src/main/java/org/apache/kafka/clients/admin/NewPartitions.java	29
clients/src/main/java/org/apache/kafka/clients/admin/LogDirDescription.java	26
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClusterOptions.java	17
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsResult.java	18
clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenOptions.java	24
clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java	165
clients/src/main/java/org/apache/kafka/clients/admin/DescribeDelegationTokenOptions.java	15
clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsResult.java	19
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java	48
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsResult.java	26
clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsResult.java	31
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConsumerGroupsResult.java	34
clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java	175
clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasOptions.java	13
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/AbstractOptions.java	12
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java	61
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsResult.java	35
clients/src/main/java/org/apache/kafka/clients/admin/DescribeClientQuotasResult.java	15
clients/src/main/java/org/apache/kafka/clients/admin/ListTopicsOptions.java	17
clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsOptions.java	6
clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigOp.java	61
clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsResult.java	65
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java	273
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java	144
clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java	45
clients/src/main/java/org/apache/kafka/clients/StaleMetadataException.java	9
clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java	18
clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java	20
clients/src/main/java/org/apache/kafka/clients/Metadata.java	369
clients/src/main/java/org/apache/kafka/clients/ConnectionState.java	10
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java	310
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java	903
clients/src/main/java/org/apache/kafka/clients/ApiVersions.java	32
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndTimestamp.java	48
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerInterceptor.java	9
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java	50
clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java	49
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java	451
clients/src/main/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignor.java	62
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.java	59
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java	76
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java	66
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsForLeaderEpochClient.java	98
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java	84
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java	212
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java	5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java	1046
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignorAdapter.java	93
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoOpConsumerRebalanceListener.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java	795
clients/src/main/java/org/apache/kafka/clients/consumer/internals/KafkaConsumerMetrics.java	61
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureAdapter.java	7
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java	691
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java	1432
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetrics.java	26
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java	94
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetadata.java	56
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java	1047
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java	136
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureListener.java	5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetcherMetricsRegistry.java	143
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java	453
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncClient.java	49
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java	63
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptors.java	47
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java	140
clients/src/main/java/org/apache/kafka/clients/consumer/RetriableCommitFailedException.java	15
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetCommitCallback.java	8
clients/src/main/java/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java	25
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java	4
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java	23
clients/src/main/java/org/apache/kafka/clients/consumer/LogTruncationException.java	16
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndMetadata.java	59
clients/src/main/java/org/apache/kafka/clients/consumer/StickyAssignor.java	96
clients/src/main/java/org/apache/kafka/clients/consumer/InvalidOffsetException.java	10
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java	879
clients/src/main/java/org/apache/kafka/clients/consumer/CommitFailedException.java	16
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java	11
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java	119
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java	450
clients/src/main/java/org/apache/kafka/clients/KafkaClient.java	37
clients/src/main/java/org/apache/kafka/clients/NetworkClientUtils.java	59
clients/src/main/java/org/apache/kafka/clients/ClientResponse.java	79
clients/src/main/java/org/apache/kafka/server/authorizer/AclCreateResult.java	18
clients/src/main/java/org/apache/kafka/server/authorizer/AclDeleteResult.java	45
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizationResult.java	7
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java	18
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizerServerInfo.java	12
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizableRequestContext.java	19
clients/src/main/java/org/apache/kafka/server/authorizer/Action.java	68
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaType.java	7
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaCallback.java	14
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaEntity.java	15
clients/src/main/java/org/apache/kafka/server/policy/AlterConfigPolicy.java	27
clients/src/main/java/org/apache/kafka/server/policy/CreateTopicPolicy.java	47
clients/src/main/java/org/apache/kafka/common/metrics/MeasurableStat.java	3
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java	24
clients/src/main/java/org/apache/kafka/common/metrics/QuotaViolationException.java	36
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetricsContext.java	18
clients/src/main/java/org/apache/kafka/common/metrics/MetricConfig.java	64
clients/src/main/java/org/apache/kafka/common/metrics/Gauge.java	4
clients/src/main/java/org/apache/kafka/common/metrics/MetricsContext.java	8
clients/src/main/java/org/apache/kafka/common/metrics/Stat.java	4
clients/src/main/java/org/apache/kafka/common/metrics/internals/IntGaugeSuite.java	184
clients/src/main/java/org/apache/kafka/common/metrics/internals/MetricsUtils.java	24
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java	64
clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java	268
clients/src/main/java/org/apache/kafka/common/metrics/MetricValueProvider.java	2
clients/src/main/java/org/apache/kafka/common/metrics/Measurable.java	4
clients/src/main/java/org/apache/kafka/common/metrics/CompoundStat.java	21
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentiles.java	109
clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentile.java	17
clients/src/main/java/org/apache/kafka/common/metrics/stats/Avg.java	22
clients/src/main/java/org/apache/kafka/common/metrics/stats/CumulativeCount.java	8
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java	44
clients/src/main/java/org/apache/kafka/common/metrics/stats/Count.java	4
clients/src/main/java/org/apache/kafka/common/metrics/stats/WindowedCount.java	8
clients/src/main/java/org/apache/kafka/common/metrics/stats/Sum.java	4
clients/src/main/java/org/apache/kafka/common/metrics/stats/SimpleRate.java	10
clients/src/main/java/org/apache/kafka/common/metrics/stats/Max.java	22
clients/src/main/java/org/apache/kafka/common/metrics/stats/Min.java	22
clients/src/main/java/org/apache/kafka/common/metrics/stats/Meter.java	43
clients/src/main/java/org/apache/kafka/common/metrics/stats/WindowedSum.java	19
clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java	47
clients/src/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java	87
clients/src/main/java/org/apache/kafka/common/metrics/stats/Value.java	14
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequencies.java	112
clients/src/main/java/org/apache/kafka/common/metrics/stats/CumulativeSum.java	20
clients/src/main/java/org/apache/kafka/common/metrics/stats/Histogram.java	129
clients/src/main/java/org/apache/kafka/common/metrics/stats/Frequency.java	16
clients/src/main/java/org/apache/kafka/common/metrics/stats/Total.java	4
clients/src/main/java/org/apache/kafka/common/metrics/Quota.java	45
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java	222
clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java	329
clients/src/main/java/org/apache/kafka/common/PartitionInfo.java	65
clients/src/main/java/org/apache/kafka/common/Node.java	75
clients/src/main/java/org/apache/kafka/common/MetricName.java	56
clients/src/main/java/org/apache/kafka/common/ClusterResource.java	26
clients/src/main/java/org/apache/kafka/common/record/AbstractRecords.java	102
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java	486
clients/src/main/java/org/apache/kafka/common/record/EndTransactionMarker.java	83
clients/src/main/java/org/apache/kafka/common/record/BaseRecords.java	5
clients/src/main/java/org/apache/kafka/common/record/FileLogInputStream.java	185
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java	192
clients/src/main/java/org/apache/kafka/common/record/CompressionRatioEstimator.java	58
clients/src/main/java/org/apache/kafka/common/record/SimpleRecord.java	79
clients/src/main/java/org/apache/kafka/common/record/Records.java	23
clients/src/main/java/org/apache/kafka/common/record/LazyDownConversionRecordsSend.java	57
clients/src/main/java/org/apache/kafka/common/record/LegacyRecord.java	338
clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java	485
clients/src/main/java/org/apache/kafka/common/record/MultiRecordsSend.java	89
clients/src/main/java/org/apache/kafka/common/record/RecordBatchIterator.java	21
clients/src/main/java/org/apache/kafka/common/record/RecordBatch.java	38
clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java	270
clients/src/main/java/org/apache/kafka/common/record/MutableRecordBatch.java	10
clients/src/main/java/org/apache/kafka/common/record/RecordsSend.java	51
clients/src/main/java/org/apache/kafka/common/record/ByteBufferLogInputStream.java	47
clients/src/main/java/org/apache/kafka/common/record/LazyDownConversionRecords.java	110
clients/src/main/java/org/apache/kafka/common/record/CompressionType.java	159
clients/src/main/java/org/apache/kafka/common/record/PartialDefaultRecord.java	67
clients/src/main/java/org/apache/kafka/common/record/RecordConversionStats.java	34
clients/src/main/java/org/apache/kafka/common/record/ConvertedRecords.java	15
clients/src/main/java/org/apache/kafka/common/record/TimestampType.java	21
clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java	5
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java	327
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java	471
clients/src/main/java/org/apache/kafka/common/record/RecordsUtil.java	87
clients/src/main/java/org/apache/kafka/common/record/Record.java	23
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordsSend.java	15
clients/src/main/java/org/apache/kafka/common/record/AbstractRecordBatch.java	15
clients/src/main/java/org/apache/kafka/common/record/RecordVersion.java	20
clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java	58
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java	524
clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java	457
clients/src/main/java/org/apache/kafka/common/record/BufferSupplier.java	72
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/memory/GarbageCollectedMemoryPool.java	110
clients/src/main/java/org/apache/kafka/common/cache/Cache.java	7
clients/src/main/java/org/apache/kafka/common/cache/LRUCache.java	30
clients/src/main/java/org/apache/kafka/common/cache/SynchronizedCache.java	23
clients/src/main/java/org/apache/kafka/common/ConsumerGroupState.java	29
clients/src/main/java/org/apache/kafka/common/config/ConfigTransformerResult.java	17
clients/src/main/java/org/apache/kafka/common/config/SaslConfigs.java	96
clients/src/main/java/org/apache/kafka/common/config/types/Password.java	26
clients/src/main/java/org/apache/kafka/common/config/SecurityConfig.java	7
clients/src/main/java/org/apache/kafka/common/config/ConfigResource.java	61
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java	984
clients/src/main/java/org/apache/kafka/common/config/ConfigData.java	20
clients/src/main/java/org/apache/kafka/common/config/provider/DirectoryConfigProvider.java	59
clients/src/main/java/org/apache/kafka/common/config/provider/ConfigProvider.java	19
clients/src/main/java/org/apache/kafka/common/config/provider/FileConfigProvider.java	61
clients/src/main/java/org/apache/kafka/common/config/ConfigTransformer.java	107
clients/src/main/java/org/apache/kafka/common/config/ConfigValue.java	79
clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java	60
clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java	123
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java	133
clients/src/main/java/org/apache/kafka/common/config/ConfigChangeCallback.java	5
clients/src/main/java/org/apache/kafka/common/config/LogLevelConfig.java	16
clients/src/main/java/org/apache/kafka/common/config/ConfigException.java	14
clients/src/main/java/org/apache/kafka/common/config/Config.java	11
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java	359
clients/src/main/java/org/apache/kafka/common/config/SslClientAuth.java	24
clients/src/main/java/org/apache/kafka/common/security/token/delegation/DelegationToken.java	47
clients/src/main/java/org/apache/kafka/common/security/token/delegation/internals/DelegationTokenCache.java	81
clients/src/main/java/org/apache/kafka/common/security/token/delegation/internals/DelegationTokenCredentialCallback.java	18
clients/src/main/java/org/apache/kafka/common/security/token/delegation/TokenInformation.java	93
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosError.java	72
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosShortNamer.java	63
clients/src/main/java/org/apache/kafka/common/security/kerberos/NoMatchingRule.java	7
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java	289
clients/src/main/java/org/apache/kafka/common/security/kerberos/BadFormatString.java	10
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosClientCallbackHandler.java	51
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	141
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java	347
clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java	265
clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java	156
clients/src/main/java/org/apache/kafka/common/security/JaasConfig.java	83
clients/src/main/java/org/apache/kafka/common/security/JaasContext.java	119
clients/src/main/java/org/apache/kafka/common/security/auth/PlaintextAuthenticationContext.java	22
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipal.java	50
clients/src/main/java/org/apache/kafka/common/security/auth/SslEngineFactory.java	15
clients/src/main/java/org/apache/kafka/common/security/auth/AuthenticationContext.java	7
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipalBuilder.java	4
clients/src/main/java/org/apache/kafka/common/security/auth/PrincipalBuilder.java	15
clients/src/main/java/org/apache/kafka/common/security/auth/AuthenticateCallbackHandler.java	9
clients/src/main/java/org/apache/kafka/common/security/auth/SaslExtensionsCallback.java	12
clients/src/main/java/org/apache/kafka/common/security/auth/Login.java	14
clients/src/main/java/org/apache/kafka/common/security/auth/SecurityProviderCreator.java	11
clients/src/main/java/org/apache/kafka/common/security/auth/SecurityProtocol.java	41
clients/src/main/java/org/apache/kafka/common/security/auth/SaslAuthenticationContext.java	30
clients/src/main/java/org/apache/kafka/common/security/auth/DefaultPrincipalBuilder.java	18
clients/src/main/java/org/apache/kafka/common/security/auth/SaslExtensions.java	28
clients/src/main/java/org/apache/kafka/common/security/auth/SslAuthenticationContext.java	28
clients/src/main/java/org/apache/kafka/common/security/plain/PlainLoginModule.java	38
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainSaslServer.java	122
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainSaslServerProvider.java	15
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainServerCallbackHandler.java	49
clients/src/main/java/org/apache/kafka/common/security/plain/PlainAuthenticateCallback.java	18
clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java	48
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerToken.java	11
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModule.java	179
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenCallback.java	37
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredJws.java	204
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerValidationUtils.java	97
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredLoginCallbackHandler.java	236
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerScopeUtils.java	25
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredValidatorCallbackHandler.java	136
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerConfigException.java	11
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerValidationResult.java	44
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerIllegalTokenException.java	16
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServerProvider.java	16
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerRefreshingLogin.java	77
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientProvider.java	16
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServer.java	176
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClient.java	146
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientCallbackHandler.java	86
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshingLogin.java	307
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshConfig.java	34
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredential.java	7
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerClientInitialResponse.java	95
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerExtensionsValidatorCallback.java	43
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallback.java	46
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredentialCallback.java	11
clients/src/main/java/org/apache/kafka/common/security/scram/ScramExtensionsCallback.java	13
clients/src/main/java/org/apache/kafka/common/security/scram/ScramLoginModule.java	47
clients/src/main/java/org/apache/kafka/common/security/scram/ScramCredential.java	25
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramMessages.java	217
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServer.java	207
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramCredentialUtils.java	53
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramFormatter.java	143
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramMechanism.java	47
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramExtensions.java	20
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramServerCallbackHandler.java	51
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServerProvider.java	16
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClientProvider.java	16
clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java	192
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java	568
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultLogin.java	10
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultKafkaPrincipalBuilder.java	112
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientCallbackHandler.java	74
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java	516
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslInternalConfigs.java	7
clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java	156
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerCallbackHandler.java	46
clients/src/main/java/org/apache/kafka/common/security/authenticator/AbstractLogin.java	74
clients/src/main/java/org/apache/kafka/common/security/authenticator/CredentialCache.java	41
clients/src/main/java/org/apache/kafka/common/IsolationLevel.java	21
clients/src/main/java/org/apache/kafka/common/serialization/ByteArraySerializer.java	7
clients/src/main/java/org/apache/kafka/common/serialization/BytesDeserializer.java	9
clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java	15
clients/src/main/java/org/apache/kafka/common/serialization/VoidSerializer.java	7
clients/src/main/java/org/apache/kafka/common/serialization/UUIDSerializer.java	28
clients/src/main/java/org/apache/kafka/common/serialization/FloatDeserializer.java	18
clients/src/main/java/org/apache/kafka/common/serialization/Serde.java	12
clients/src/main/java/org/apache/kafka/common/serialization/DoubleDeserializer.java	18
clients/src/main/java/org/apache/kafka/common/serialization/ByteBufferSerializer.java	19
clients/src/main/java/org/apache/kafka/common/serialization/ExtendedDeserializer.java	32
clients/src/main/java/org/apache/kafka/common/serialization/VoidDeserializer.java	9
clients/src/main/java/org/apache/kafka/common/serialization/FloatSerializer.java	15
clients/src/main/java/org/apache/kafka/common/serialization/ByteBufferDeserializer.java	9
clients/src/main/java/org/apache/kafka/common/serialization/LongSerializer.java	17
clients/src/main/java/org/apache/kafka/common/serialization/UUIDDeserializer.java	30
clients/src/main/java/org/apache/kafka/common/serialization/StringDeserializer.java	27
clients/src/main/java/org/apache/kafka/common/serialization/IntegerDeserializer.java	17
clients/src/main/java/org/apache/kafka/common/serialization/StringSerializer.java	27
clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java	165
clients/src/main/java/org/apache/kafka/common/serialization/LongDeserializer.java	17
clients/src/main/java/org/apache/kafka/common/serialization/ByteArrayDeserializer.java	7
clients/src/main/java/org/apache/kafka/common/serialization/IntegerSerializer.java	13
clients/src/main/java/org/apache/kafka/common/serialization/DoubleSerializer.java	19
clients/src/main/java/org/apache/kafka/common/serialization/ShortDeserializer.java	17
clients/src/main/java/org/apache/kafka/common/serialization/BytesSerializer.java	9
clients/src/main/java/org/apache/kafka/common/serialization/ExtendedSerializer.java	32
clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java	15
clients/src/main/java/org/apache/kafka/common/serialization/ShortSerializer.java	11
clients/src/main/java/org/apache/kafka/common/Metric.java	7
clients/src/main/java/org/apache/kafka/common/InvalidRecordException.java	11
clients/src/main/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java	28
clients/src/main/java/org/apache/kafka/common/network/DelayedResponseAuthenticationException.java	8
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java	164
clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java	331
clients/src/main/java/org/apache/kafka/common/network/NetworkReceive.java	118
clients/src/main/java/org/apache/kafka/common/network/Mode.java	2
clients/src/main/java/org/apache/kafka/common/network/ChannelState.java	42
clients/src/main/java/org/apache/kafka/common/network/CipherInformation.java	37
clients/src/main/java/org/apache/kafka/common/network/TransportLayers.java	10
clients/src/main/java/org/apache/kafka/common/network/Selectable.java	24
clients/src/main/java/org/apache/kafka/common/network/Send.java	9
clients/src/main/java/org/apache/kafka/common/network/ChannelMetadataRegistry.java	9
clients/src/main/java/org/apache/kafka/common/network/NetworkSend.java	13
clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java	353
clients/src/main/java/org/apache/kafka/common/network/ReauthenticationContext.java	21
clients/src/main/java/org/apache/kafka/common/network/TransportLayer.java	25
clients/src/main/java/org/apache/kafka/common/network/ListenerReconfigurable.java	5
clients/src/main/java/org/apache/kafka/common/network/Receive.java	11
clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java	52
clients/src/main/java/org/apache/kafka/common/network/Authenticator.java	30
clients/src/main/java/org/apache/kafka/common/network/Selector.java	1023
clients/src/main/java/org/apache/kafka/common/network/ListenerName.java	45
clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java	129
clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java	76
clients/src/main/java/org/apache/kafka/common/network/InvalidReceiveException.java	10
clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java	107
clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java	660
clients/src/main/java/org/apache/kafka/common/network/ChannelBuilder.java	11
clients/src/main/java/org/apache/kafka/common/network/ClientInformation.java	39
clients/src/main/java/org/apache/kafka/common/Configurable.java	5
clients/src/main/java/org/apache/kafka/common/TopicPartition.java	45
clients/src/main/java/org/apache/kafka/common/Cluster.java	213
clients/src/main/java/org/apache/kafka/common/annotation/InterfaceStability.java	16
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferOutputStream.java	65
clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java	30
clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java	186
clients/src/main/java/org/apache/kafka/common/utils/SystemScheduler.java	18
clients/src/main/java/org/apache/kafka/common/utils/LoggingSignalHandler.java	64
clients/src/main/java/org/apache/kafka/common/utils/KafkaThread.java	24
clients/src/main/java/org/apache/kafka/common/utils/PrimitiveRef.java	12
clients/src/main/java/org/apache/kafka/common/utils/OperatingSystem.java	14
clients/src/main/java/org/apache/kafka/common/utils/MappedIterator.java	19
clients/src/main/java/org/apache/kafka/common/utils/FixedOrderMap.java	25
clients/src/main/java/org/apache/kafka/common/utils/Checksums.java	35
clients/src/main/java/org/apache/kafka/common/utils/LogContext.java	631
clients/src/main/java/org/apache/kafka/common/utils/ProducerIdAndEpoch.java	32
clients/src/main/java/org/apache/kafka/common/utils/Bytes.java	116
clients/src/main/java/org/apache/kafka/common/utils/Scheduler.java	10
clients/src/main/java/org/apache/kafka/common/utils/CollectionUtils.java	35
clients/src/main/java/org/apache/kafka/common/utils/Shell.java	168
clients/src/main/java/org/apache/kafka/common/utils/Utils.java	723
clients/src/main/java/org/apache/kafka/common/utils/SecurityUtils.java	110
clients/src/main/java/org/apache/kafka/common/utils/Time.java	20
clients/src/main/java/org/apache/kafka/common/utils/AppInfoParser.java	111
clients/src/main/java/org/apache/kafka/common/utils/CloseableIterator.java	24
clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java	24
clients/src/main/java/org/apache/kafka/common/utils/Timer.java	51
clients/src/main/java/org/apache/kafka/common/utils/Crc32C.java	57
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferUnmapper.java	83
clients/src/main/java/org/apache/kafka/common/utils/PureJavaCrc32C.java	582
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java	401
clients/src/main/java/org/apache/kafka/common/utils/AbstractIterator.java	56
clients/src/main/java/org/apache/kafka/common/utils/FlattenedIterator.java	22
clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiCollection.java	74
clients/src/main/java/org/apache/kafka/common/utils/Sanitizer.java	41
clients/src/main/java/org/apache/kafka/common/utils/Crc32.java	314
clients/src/main/java/org/apache/kafka/common/utils/ThreadUtils.java	23
clients/src/main/java/org/apache/kafka/common/utils/Java.java	40
clients/src/main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java	23
clients/src/main/java/org/apache/kafka/common/utils/Exit.java	66
clients/src/main/java/org/apache/kafka/common/utils/CircularIterator.java	41
clients/src/main/java/org/apache/kafka/common/utils/CopyOnWriteMap.java	105
clients/src/main/java/org/apache/kafka/common/protocol/Message.java	15
clients/src/main/java/org/apache/kafka/common/protocol/RecordsReadable.java	54
clients/src/main/java/org/apache/kafka/common/protocol/types/RawTaggedField.java	31
clients/src/main/java/org/apache/kafka/common/protocol/types/TaggedFields.java	141
clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java	866
clients/src/main/java/org/apache/kafka/common/protocol/types/Schema.java	143
clients/src/main/java/org/apache/kafka/common/protocol/types/SchemaException.java	11
clients/src/main/java/org/apache/kafka/common/protocol/types/BoundField.java	15
clients/src/main/java/org/apache/kafka/common/protocol/types/RawTaggedFieldWriter.java	48
clients/src/main/java/org/apache/kafka/common/protocol/types/ArrayOf.java	92
clients/src/main/java/org/apache/kafka/common/protocol/types/Field.java	136
clients/src/main/java/org/apache/kafka/common/protocol/types/CompactArrayOf.java	99
clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java	401
clients/src/main/java/org/apache/kafka/common/protocol/ObjectSerializationCache.java	23
clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java	151
clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java	346
clients/src/main/java/org/apache/kafka/common/protocol/ByteBufferAccessor.java	76
clients/src/main/java/org/apache/kafka/common/protocol/Writable.java	17
clients/src/main/java/org/apache/kafka/common/protocol/RecordsWritable.java	71
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java	400
clients/src/main/java/org/apache/kafka/common/protocol/Readable.java	34
clients/src/main/java/org/apache/kafka/common/protocol/ApiMessage.java	4
clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java	143
clients/src/main/java/org/apache/kafka/common/protocol/CommonFields.java	23
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenResponse.java	44
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java	82
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java	73
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsRequest.java	53
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownRequest.java	53
clients/src/main/java/org/apache/kafka/common/requests/RenewDelegationTokenRequest.java	50
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java	100
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java	130
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java	73
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java	138
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java	83
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsRequest.java	57
clients/src/main/java/org/apache/kafka/common/requests/FetchMetadata.java	73
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java	44
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java	38
clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnRequest.java	46
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java	274
clients/src/main/java/org/apache/kafka/common/requests/RequestHeader.java	105
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java	81
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaResponse.java	42
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupRequest.java	67
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java	87
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenRequest.java	53
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasRequest.java	88
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java	140
clients/src/main/java/org/apache/kafka/common/requests/ExpireDelegationTokenResponse.java	44
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateRequest.java	55
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java	67
clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java	91
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java	52
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsRequest.java	96
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java	202
clients/src/main/java/org/apache/kafka/common/requests/RequestAndSize.java	9
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsRequest.java	78
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java	111
clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java	111
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java	105
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java	172
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java	42
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java	61
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsRequest.java	69
clients/src/main/java/org/apache/kafka/common/requests/EpochEndOffset.java	56
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java	99
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteResponse.java	47
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java	109
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java	260
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeResponse.java	34
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java	46
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetResponse.java	211
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenRequest.java	47
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java	94
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsRequest.java	82
clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsRequest.java	60
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java	76
clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java	45
clients/src/main/java/org/apache/kafka/common/requests/ControlledShutdownResponse.java	48
clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteRequest.java	52
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsRequest.java	74
clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java	120
clients/src/main/java/org/apache/kafka/common/requests/ApiError.java	63
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsRequest.java	101
clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersRequest.java	163
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java	90
clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java	387
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsRequest.java	60
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersRequest.java	95
clients/src/main/java/org/apache/kafka/common/requests/AbstractControlRequest.java	22
clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java	216
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/ListGroupsRequest.java	59
clients/src/main/java/org/apache/kafka/common/requests/ListPartitionReassignmentsResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java	174
clients/src/main/java/org/apache/kafka/common/requests/SaslAuthenticateResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java	279
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java	88
clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java	45
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java	39
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataResponse.java	30
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java	59
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java	46
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java	153
clients/src/main/java/org/apache/kafka/common/requests/CreatePartitionsResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java	46
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java	43
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java	160
clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsResponse.java	48
clients/src/main/java/org/apache/kafka/common/requests/ResponseHeader.java	39
clients/src/main/java/org/apache/kafka/common/requests/RequestUtils.java	27
clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequest.java	67
clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsResponse.java	41
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java	290
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java	188
clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeRequest.java	51
clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsRequest.java	49
clients/src/main/java/org/apache/kafka/common/requests/AbstractRequestResponse.java	3
clients/src/main/java/org/apache/kafka/common/requests/DescribeUserScramCredentialsRequest.java	54
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java	99
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorRequest.java	81
clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupResponse.java	106
clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java	116
clients/src/main/java/org/apache/kafka/common/requests/UpdateMetadataRequest.java	165
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasRequest.java	96
clients/src/main/java/org/apache/kafka/common/requests/EndTxnRequest.java	53
clients/src/main/java/org/apache/kafka/common/requests/TransactionResult.java	14
clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsRequest.java	57
clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java	305
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java	38
clients/src/main/java/org/apache/kafka/common/requests/StopReplicaRequest.java	175
clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java	127
clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java	68
clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java	62
clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenRequest.java	54
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java	213
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/Topic.java	44
clients/src/main/java/org/apache/kafka/common/internals/InvalidProducerEpochException.java	8
clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java	113
clients/src/main/java/org/apache/kafka/common/TopicPartitionInfo.java	51
clients/src/main/java/org/apache/kafka/common/TopicPartitionReplica.java	51
clients/src/main/java/org/apache/kafka/common/KafkaException.java	16
clients/src/main/java/org/apache/kafka/common/Endpoint.java	57
clients/src/main/java/org/apache/kafka/common/MetricNameTemplate.java	55
clients/src/main/java/org/apache/kafka/common/KafkaFuture.java	74
clients/src/main/java/org/apache/kafka/common/ElectionType.java	22
clients/src/main/java/org/apache/kafka/common/feature/SupportedVersionRange.java	14
clients/src/main/java/org/apache/kafka/common/feature/BaseVersionRange.java	66
clients/src/main/java/org/apache/kafka/common/feature/FinalizedVersionRange.java	17
clients/src/main/java/org/apache/kafka/common/feature/Features.java	83
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaAlteration.java	50
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaFilterComponent.java	41
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaFilter.java	42
clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaEntity.java	29
clients/src/main/java/org/apache/kafka/common/replica/RackAwareReplicaSelector.java	28
clients/src/main/java/org/apache/kafka/common/replica/ClientMetadata.java	71
clients/src/main/java/org/apache/kafka/common/replica/ReplicaView.java	57
clients/src/main/java/org/apache/kafka/common/replica/ReplicaSelector.java	18
clients/src/main/java/org/apache/kafka/common/replica/PartitionView.java	43
clients/src/main/java/org/apache/kafka/common/errors/GroupMaxSizeReachedException.java	7
clients/src/main/java/org/apache/kafka/common/errors/IllegalGenerationException.java	16
clients/src/main/java/org/apache/kafka/common/errors/ApiException.java	21
clients/src/main/java/org/apache/kafka/common/errors/SaslAuthenticationException.java	11
clients/src/main/java/org/apache/kafka/common/errors/InvalidMetadataException.java	16
clients/src/main/java/org/apache/kafka/common/errors/GroupNotEmptyException.java	6
clients/src/main/java/org/apache/kafka/common/errors/NotControllerException.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/ResourceNotFoundException.java	22
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedCompressionTypeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidCommitOffsetSizeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnknownLeaderEpochException.java	10
clients/src/main/java/org/apache/kafka/common/errors/LeaderNotAvailableException.java	10
clients/src/main/java/org/apache/kafka/common/errors/FetchSessionIdNotFoundException.java	9
clients/src/main/java/org/apache/kafka/common/errors/LogDirNotFoundException.java	13
clients/src/main/java/org/apache/kafka/common/errors/ElectionNotNeededException.java	9
clients/src/main/java/org/apache/kafka/common/errors/InvalidConfigurationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/CoordinatorLoadInProgressException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnStateException.java	6
clients/src/main/java/org/apache/kafka/common/errors/TopicAuthorizationException.java	19
clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java	15
clients/src/main/java/org/apache/kafka/common/errors/RecordTooLargeException.java	26
clients/src/main/java/org/apache/kafka/common/errors/DuplicateResourceException.java	22
clients/src/main/java/org/apache/kafka/common/errors/UnknownServerException.java	15
clients/src/main/java/org/apache/kafka/common/errors/ReassignmentInProgressException.java	9
clients/src/main/java/org/apache/kafka/common/errors/GroupIdNotFoundException.java	6
clients/src/main/java/org/apache/kafka/common/errors/OffsetNotAvailableException.java	7
clients/src/main/java/org/apache/kafka/common/errors/ClusterAuthorizationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/OutOfOrderSequenceException.java	6
clients/src/main/java/org/apache/kafka/common/errors/KafkaStorageException.java	16
clients/src/main/java/org/apache/kafka/common/errors/InterruptException.java	17
clients/src/main/java/org/apache/kafka/common/errors/CoordinatorNotAvailableException.java	14
clients/src/main/java/org/apache/kafka/common/errors/GroupAuthorizationException.java	17
clients/src/main/java/org/apache/kafka/common/errors/InvalidReplicaAssignmentException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ThrottlingQuotaExceededException.java	14
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderForPartitionException.java	17
clients/src/main/java/org/apache/kafka/common/errors/NotLeaderOrFollowerException.java	17
clients/src/main/java/org/apache/kafka/common/errors/UnknownProducerIdException.java	6
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenDisabledException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ConcurrentTransactionsException.java	7
clients/src/main/java/org/apache/kafka/common/errors/PolicyViolationException.java	9
clients/src/main/java/org/apache/kafka/common/errors/BrokerNotAvailableException.java	10
clients/src/main/java/org/apache/kafka/common/errors/IllegalSaslStateException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnacceptableCredentialException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedByAuthenticationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/GroupSubscribedToTopicException.java	6
clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java	16
clients/src/main/java/org/apache/kafka/common/errors/InvalidPartitionsException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidSessionTimeoutException.java	10
clients/src/main/java/org/apache/kafka/common/errors/NotCoordinatorException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnknownMemberIdException.java	16
clients/src/main/java/org/apache/kafka/common/errors/MemberIdRequiredException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ProducerFencedException.java	6
clients/src/main/java/org/apache/kafka/common/errors/StaleBrokerEpochException.java	10
clients/src/main/java/org/apache/kafka/common/errors/FencedLeaderEpochException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidFetchSessionEpochException.java	9
clients/src/main/java/org/apache/kafka/common/errors/AuthorizationException.java	9
clients/src/main/java/org/apache/kafka/common/errors/SerializationException.java	21
clients/src/main/java/org/apache/kafka/common/errors/InvalidTimestampException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidFetchSizeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidPrincipalTypeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ReplicaNotAvailableException.java	13
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequiredAcksException.java	7
clients/src/main/java/org/apache/kafka/common/errors/InvalidTxnTimeoutException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidTopicException.java	30
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenAuthorizationException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedSaslMechanismException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ControllerMovedException.java	10
clients/src/main/java/org/apache/kafka/common/errors/OffsetOutOfRangeException.java	10
clients/src/main/java/org/apache/kafka/common/errors/TimeoutException.java	16
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenNotFoundException.java	10
clients/src/main/java/org/apache/kafka/common/errors/PreferredLeaderNotAvailableException.java	9
clients/src/main/java/org/apache/kafka/common/errors/TopicExistsException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidRequestException.java	10
clients/src/main/java/org/apache/kafka/common/errors/WakeupException.java	5
clients/src/main/java/org/apache/kafka/common/errors/AuthenticationException.java	14
clients/src/main/java/org/apache/kafka/common/errors/TransactionalIdAuthorizationException.java	6
clients/src/main/java/org/apache/kafka/common/errors/OffsetMetadataTooLarge.java	15
clients/src/main/java/org/apache/kafka/common/errors/DelegationTokenExpiredException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidOffsetException.java	10
clients/src/main/java/org/apache/kafka/common/errors/OperationNotAttemptedException.java	6
clients/src/main/java/org/apache/kafka/common/errors/InvalidPidMappingException.java	6
clients/src/main/java/org/apache/kafka/common/errors/RecordBatchTooLargeException.java	16
clients/src/main/java/org/apache/kafka/common/errors/InvalidGroupIdException.java	10
clients/src/main/java/org/apache/kafka/common/errors/EligibleLeadersNotAvailableException.java	9
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedVersionException.java	11
clients/src/main/java/org/apache/kafka/common/errors/FencedInstanceIdException.java	10
clients/src/main/java/org/apache/kafka/common/errors/UnsupportedForMessageFormatException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InvalidReplicationFactorException.java	10
clients/src/main/java/org/apache/kafka/common/errors/NoReassignmentInProgressException.java	9
clients/src/main/java/org/apache/kafka/common/errors/NetworkException.java	16
clients/src/main/java/org/apache/kafka/common/errors/NotEnoughReplicasException.java	16
clients/src/main/java/org/apache/kafka/common/errors/RebalanceInProgressException.java	16
clients/src/main/java/org/apache/kafka/common/errors/TopicDeletionDisabledException.java	9
clients/src/main/java/org/apache/kafka/common/errors/DuplicateSequenceException.java	6
clients/src/main/java/org/apache/kafka/common/errors/SslAuthenticationException.java	11
clients/src/main/java/org/apache/kafka/common/errors/UnstableOffsetCommitException.java	7
clients/src/main/java/org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.java	7
clients/src/main/java/org/apache/kafka/common/errors/RetriableException.java	15
clients/src/main/java/org/apache/kafka/common/errors/SecurityDisabledException.java	10
clients/src/main/java/org/apache/kafka/common/errors/ListenerNotFoundException.java	10
clients/src/main/java/org/apache/kafka/common/errors/TransactionCoordinatorFencedException.java	10
clients/src/main/java/org/apache/kafka/common/errors/InconsistentGroupProtocolException.java	10
clients/src/main/java/org/apache/kafka/common/resource/Resource.java	43
clients/src/main/java/org/apache/kafka/common/resource/PatternType.java	44
clients/src/main/java/org/apache/kafka/common/resource/ResourceFilter.java	55
clients/src/main/java/org/apache/kafka/common/resource/ResourceType.java	44
clients/src/main/java/org/apache/kafka/common/resource/ResourcePattern.java	55
clients/src/main/java/org/apache/kafka/common/resource/ResourcePatternFilter.java	85
clients/src/main/java/org/apache/kafka/common/ClusterResourceListener.java	4
clients/src/main/java/org/apache/kafka/common/Reconfigurable.java	9
clients/src/main/java/org/apache/kafka/common/acl/AclBinding.java	47
clients/src/main/java/org/apache/kafka/common/acl/AclOperation.java	50
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	62
clients/src/main/java/org/apache/kafka/common/acl/AclPermissionType.java	41
clients/src/main/java/org/apache/kafka/common/acl/AclBindingFilter.java	57
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	152
clients/src/main/java/org/apache/kafka/common/header/Header.java	5
clients/src/main/java/org/apache/kafka/common/MessageFormatter.java	17
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java	30
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java	343
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java	312
tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java	400
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java	532
tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java	67
tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java	459
tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java	183
tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java	256
tools/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java	484
tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java	124
tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java	237
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorRestResource.java	109
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java	460
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicTopology.java	34
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicPlatform.java	82
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicNode.java	83
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java	271
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentRestResource.java	71
tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java	186
tools/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java	498
tools/src/main/java/org/apache/kafka/trogdor/common/JsonUtil.java	50
tools/src/main/java/org/apache/kafka/trogdor/common/Node.java	26
tools/src/main/java/org/apache/kafka/trogdor/common/Topology.java	20
tools/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java	219
tools/src/main/java/org/apache/kafka/trogdor/common/StringFormatter.java	68
tools/src/main/java/org/apache/kafka/trogdor/common/Platform.java	33
tools/src/main/java/org/apache/kafka/trogdor/common/StringExpander.java	30
tools/src/main/java/org/apache/kafka/trogdor/task/AgentWorkerStatusTracker.java	16
tools/src/main/java/org/apache/kafka/trogdor/task/TaskController.java	6
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/TaskSpec.java	50
tools/src/main/java/org/apache/kafka/trogdor/task/TaskWorker.java	8
tools/src/main/java/org/apache/kafka/trogdor/task/WorkerStatusTracker.java	5
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskWorker.java	26
tools/src/main/java/org/apache/kafka/trogdor/workload/PayloadKeyType.java	12
tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionSpec.java	121
tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandSpec.java	56
tools/src/main/java/org/apache/kafka/trogdor/workload/PartitionsSpec.java	90
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java	263
tools/src/main/java/org/apache/kafka/trogdor/workload/TransactionGenerator.java	16
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java	440
tools/src/main/java/org/apache/kafka/trogdor/workload/PayloadGenerator.java	16
tools/src/main/java/org/apache/kafka/trogdor/workload/RandomComponentPayloadGenerator.java	56
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpec.java	137
tools/src/main/java/org/apache/kafka/trogdor/workload/TopicsSpec.java	43
tools/src/main/java/org/apache/kafka/trogdor/workload/TimeIntervalTransactionsGenerator.java	38
tools/src/main/java/org/apache/kafka/trogdor/workload/Throttle.java	46
tools/src/main/java/org/apache/kafka/trogdor/workload/RandomComponent.java	21
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java	388
tools/src/main/java/org/apache/kafka/trogdor/workload/UniformTransactionsGenerator.java	30
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java	95
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressSpec.java	72
tools/src/main/java/org/apache/kafka/trogdor/workload/SequentialPayloadGenerator.java	34
tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionWorker.java	396
tools/src/main/java/org/apache/kafka/trogdor/workload/ConstantPayloadGenerator.java	29
tools/src/main/java/org/apache/kafka/trogdor/workload/PayloadIterator.java	27
tools/src/main/java/org/apache/kafka/trogdor/workload/NullPayloadGenerator.java	11
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java	341
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java	126
tools/src/main/java/org/apache/kafka/trogdor/workload/Histogram.java	127
tools/src/main/java/org/apache/kafka/trogdor/workload/UniformRandomPayloadGenerator.java	54
tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java	282
tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultController.java	14
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultController.java	14
tools/src/main/java/org/apache/kafka/trogdor/fault/FilesUnreadableFaultSpec.java	53
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultSpec.java	47
tools/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultWorker.java	113
tools/src/main/java/org/apache/kafka/trogdor/fault/Kibosh.java	144
tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultWorker.java	37
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultController.java	20
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultWorker.java	60
tools/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultSpec.java	63
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultSpec.java	38
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultWorker.java	62
tools/src/main/java/org/apache/kafka/trogdor/rest/Message.java	19
tools/src/main/java/org/apache/kafka/trogdor/rest/RequestConflictException.java	10
tools/src/main/java/org/apache/kafka/trogdor/rest/UptimeResponse.java	21
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStateType.java	19
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskPending.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerReceiving.java	17
tools/src/main/java/org/apache/kafka/trogdor/rest/RestExceptionMapper.java	56
tools/src/main/java/org/apache/kafka/trogdor/rest/DestroyWorkerRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerRunning.java	33
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskState.java	33
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStopping.java	37
tools/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorShutdownRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/AgentStatusResponse.java	22
tools/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java	190
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerDone.java	47
tools/src/main/java/org/apache/kafka/trogdor/rest/StopWorkerRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/TasksRequest.java	76
tools/src/main/java/org/apache/kafka/trogdor/rest/DestroyTaskRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerState.java	46
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStopping.java	23
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateTaskRequest.java	22
tools/src/main/java/org/apache/kafka/trogdor/rest/StopTaskRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRunning.java	23
tools/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorStatusResponse.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateWorkerRequest.java	29
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStarting.java	17
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskDone.java	44
tools/src/main/java/org/apache/kafka/trogdor/rest/ErrorResponse.java	39
tools/src/main/java/org/apache/kafka/trogdor/rest/TasksResponse.java	18
tools/src/main/java/org/apache/kafka/trogdor/rest/Empty.java	23
core/src/main/java/kafka/metrics/KafkaYammerMetrics.java	38
core/src/main/java/kafka/metrics/FilteringJmxReporter.java	36
core/src/main/scala/org/apache/zookeeper/ZooKeeperMainWithTlsSupportForKafka.scala	62
core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala	10
core/src/main/scala/kafka/metrics/LinuxIoMetricsCollector.scala	59
core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala	58
core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala	51
core/src/main/scala/kafka/metrics/KafkaTimer.scala	9
core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala	38
core/src/main/scala/kafka/cluster/Broker.scala	57
core/src/main/scala/kafka/cluster/BrokerEndPoint.scala	40
core/src/main/scala/kafka/cluster/Partition.scala	827
core/src/main/scala/kafka/cluster/Replica.scala	54
core/src/main/scala/kafka/cluster/EndPoint.scala	39
core/src/main/scala/kafka/zk/KafkaZkClient.scala	1170
core/src/main/scala/kafka/zk/ZkSecurityMigratorUtils.scala	5
core/src/main/scala/kafka/zk/AdminZkClient.scala	278
core/src/main/scala/kafka/zk/ZkData.scala	656
core/src/main/scala/kafka/tools/DumpLogSegments.scala	351
core/src/main/scala/kafka/tools/MirrorMaker.scala	435
core/src/main/scala/kafka/tools/GetOffsetShell.scala	115
core/src/main/scala/kafka/tools/ConsumerPerformance.scala	251
core/src/main/scala/kafka/tools/StreamsResetter.java	563
core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala	408
core/src/main/scala/kafka/tools/JmxTool.scala	221
core/src/main/scala/kafka/tools/ConsoleConsumer.scala	464
core/src/main/scala/kafka/tools/StateChangeLogMerger.scala	129
core/src/main/scala/kafka/tools/ConsoleProducer.scala	256
core/src/main/scala/kafka/tools/EndToEndLatency.scala	117
core/src/main/scala/kafka/tools/PerfConfig.scala	20
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala	469
core/src/main/scala/kafka/coordinator/transaction/ProducerIdManager.scala	104
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala	321
core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala	140
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala	309
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala	484
core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala	192
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala	1049
core/src/main/scala/kafka/coordinator/group/MemberMetadata.scala	83
core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala	514
core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala	39
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala	1157
core/src/main/scala/kafka/coordinator/group/DelayedHeartbeat.scala	12
core/src/main/scala/kafka/coordinator/group/OffsetConfig.scala	24
core/src/main/scala/kafka/serializer/Decoder.scala	29
core/src/main/scala/kafka/Kafka.scala	55
core/src/main/scala/kafka/security/auth/Acl.scala	42
core/src/main/scala/kafka/security/auth/Resource.scala	42
core/src/main/scala/kafka/security/auth/Authorizer.scala	15
core/src/main/scala/kafka/security/auth/ResourceType.scala	64
core/src/main/scala/kafka/security/auth/PermissionType.scala	26
core/src/main/scala/kafka/security/auth/SimpleAclAuthorizer.scala	121
core/src/main/scala/kafka/security/auth/Operation.scala	87
core/src/main/scala/kafka/security/authorizer/AclEntry.scala	89
core/src/main/scala/kafka/security/authorizer/AuthorizerWrapper.scala	137
core/src/main/scala/kafka/security/authorizer/AclAuthorizer.scala	440
core/src/main/scala/kafka/security/authorizer/AuthorizerUtils.scala	38
core/src/main/scala/kafka/security/CredentialProvider.scala	30
core/src/main/scala/kafka/network/SocketServer.scala	1055
core/src/main/scala/kafka/network/RequestChannel.scala	396
core/src/main/scala/kafka/admin/DelegationTokenCommand.scala	162
core/src/main/scala/kafka/admin/LeaderElectionCommand.scala	232
core/src/main/scala/kafka/admin/AclCommand.scala	516
core/src/main/scala/kafka/admin/RackAwareMode.scala	7
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala	280
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala	1234
core/src/main/scala/kafka/admin/AdminUtils.scala	120
core/src/main/scala/kafka/admin/ZkSecurityMigrator.scala	229
core/src/main/scala/kafka/admin/AdminOperationException.scala	5
core/src/main/scala/kafka/admin/ConfigCommand.scala	706
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala	1008
core/src/main/scala/kafka/admin/TopicCommand.scala	649
core/src/main/scala/kafka/admin/BrokerMetadata.scala	2
core/src/main/scala/kafka/admin/PreferredReplicaLeaderElectionCommand.scala	244
core/src/main/scala/kafka/admin/DeleteRecordsCommand.scala	97
core/src/main/scala/kafka/admin/LogDirsCommand.scala	88
core/src/main/scala/kafka/message/CompressionCodec.scala	74
core/src/main/scala/kafka/server/ReplicaFetcherManager.scala	26
core/src/main/scala/kafka/server/DelayedOperationKey.scala	25
core/src/main/scala/kafka/server/ClientQuotaManager.scala	418
core/src/main/scala/kafka/server/LogDirFailureChannel.scala	14
core/src/main/scala/kafka/server/ReplicaManager.scala	1383
core/src/main/scala/kafka/server/ActionQueue.scala	22
core/src/main/scala/kafka/server/DelayedElectLeader.scala	38
core/src/main/scala/kafka/server/BrokerMetadataCheckpoint.scala	65
core/src/main/scala/kafka/server/DelayedProduce.scala	81
core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala	141
core/src/main/scala/kafka/server/FetchDataInfo.scala	11
core/src/main/scala/kafka/server/DelayedOperation.scala	208
core/src/main/scala/kafka/server/SensorAccess.scala	24
core/src/main/scala/kafka/server/checkpoints/OffsetCheckpointFile.scala	52
core/src/main/scala/kafka/server/checkpoints/CheckpointFile.scala	110
core/src/main/scala/kafka/server/checkpoints/LeaderEpochCheckpointFile.scala	32
core/src/main/scala/kafka/server/FinalizedFeatureCache.scala	45
core/src/main/scala/kafka/server/KafkaRequestHandler.scala	273
core/src/main/scala/kafka/server/ControllerMutationQuotaManager.scala	150
core/src/main/scala/kafka/server/MetadataCache.scala	282
core/src/main/scala/kafka/server/KafkaServer.scala	587
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala	249
core/src/main/scala/kafka/server/KafkaConfig.scala	1508
core/src/main/scala/kafka/server/DelayedDeleteTopics.scala	40
core/src/main/scala/kafka/server/DelegationTokenManager.scala	346
core/src/main/scala/kafka/server/LogOffsetMetadata.scala	40
core/src/main/scala/kafka/server/AbstractFetcherManager.scala	159
core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala	201
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala	715
core/src/main/scala/kafka/server/ReplicationQuotaManager.scala	99
core/src/main/scala/kafka/server/BrokerStates.scala	17
core/src/main/scala/kafka/server/AbstractFetcherThread.scala	550
core/src/main/scala/kafka/server/DelayedFuture.scala	57
core/src/main/scala/kafka/server/SupportedFeatures.scala	36
core/src/main/scala/kafka/server/DynamicConfig.scala	85
core/src/main/scala/kafka/server/DelayedCreatePartitions.scala	56
core/src/main/scala/kafka/server/ConfigHandler.scala	162
core/src/main/scala/kafka/server/ReplicaAlterLogDirsManager.scala	34
core/src/main/scala/kafka/server/FetchSession.scala	507
core/src/main/scala/kafka/server/ThrottledChannel.scala	24
core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala	54
core/src/main/scala/kafka/server/DelayedFetch.scala	117
core/src/main/scala/kafka/server/QuotaFactory.scala	107
core/src/main/scala/kafka/server/DelayedDeleteRecords.scala	76
core/src/main/scala/kafka/server/ReplicaFetcherBlockingSend.scala	99
core/src/main/scala/kafka/server/DynamicConfigManager.scala	100
core/src/main/scala/kafka/server/AdminManager.scala	1039
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala	143
core/src/main/scala/kafka/server/KafkaApis.scala	2720
core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala	128
core/src/main/scala/kafka/server/KafkaServerStartable.scala	38
core/src/main/scala/kafka/utils/DelayedItem.scala	15
core/src/main/scala/kafka/utils/Annotations.scala	5
core/src/main/scala/kafka/utils/CommandDefaultOptions.scala	8
core/src/main/scala/kafka/utils/Throttler.scala	65
core/src/main/scala/kafka/utils/KafkaScheduler.scala	80
core/src/main/scala/kafka/utils/Logging.scala	41
core/src/main/scala/kafka/utils/ToolsUtils.scala	41
core/src/main/scala/kafka/utils/Implicits.scala	12
core/src/main/scala/kafka/utils/FileLock.scala	39
core/src/main/scala/kafka/utils/timer/TimerTaskList.scala	99
core/src/main/scala/kafka/utils/timer/Timer.scala	69
core/src/main/scala/kafka/utils/timer/TimingWheel.scala	49
core/src/main/scala/kafka/utils/timer/TimerTask.scala	19
core/src/main/scala/kafka/utils/CommandLineUtils.scala	71
core/src/main/scala/kafka/utils/Mx4jLoader.scala	37
core/src/main/scala/kafka/utils/TopicFilter.scala	25
core/src/main/scala/kafka/utils/Json.scala	27
core/src/main/scala/kafka/utils/VersionInfo.scala	17
core/src/main/scala/kafka/utils/json/JsonValue.scala	40
core/src/main/scala/kafka/utils/json/DecodeJson.scala	61
core/src/main/scala/kafka/utils/json/JsonArray.scala	7
core/src/main/scala/kafka/utils/json/JsonObject.scala	13
core/src/main/scala/kafka/utils/VerifiableProperties.scala	118
core/src/main/scala/kafka/utils/QuotaUtils.scala	22
core/src/main/scala/kafka/utils/Pool.scala	38
core/src/main/scala/kafka/utils/CoreUtils.scala	180
core/src/main/scala/kafka/utils/PasswordEncoder.scala	128
core/src/main/scala/kafka/utils/Exit.scala	31
core/src/main/scala/kafka/utils/ReplicationUtils.scala	33
core/src/main/scala/kafka/utils/Log4jController.scala	68
core/src/main/scala/kafka/utils/ShutdownableThread.scala	65
core/src/main/scala/kafka/utils/NotNothing.scala	8
core/src/main/scala/kafka/zookeeper/ZooKeeperClient.scala	414
core/src/main/scala/kafka/controller/StateChangeLogger.scala	19
core/src/main/scala/kafka/controller/PartitionStateMachine.scala	405
core/src/main/scala/kafka/controller/ControllerState.scala	69
core/src/main/scala/kafka/controller/ControllerChannelManager.scala	569
core/src/main/scala/kafka/controller/Election.scala	90
core/src/main/scala/kafka/controller/ControllerContext.scala	363
core/src/main/scala/kafka/controller/ControllerEventManager.scala	114
core/src/main/scala/kafka/controller/TopicDeletionManager.scala	191
core/src/main/scala/kafka/controller/KafkaController.scala	1519
core/src/main/scala/kafka/controller/ReplicaStateMachine.scala	334
core/src/main/scala/kafka/common/InterBrokerSendThread.scala	152
core/src/main/scala/kafka/common/OffsetsOutOfOrderException.scala	3
core/src/main/scala/kafka/common/BaseEnum.scala	4
core/src/main/scala/kafka/common/TopicAlreadyMarkedForDeletionException.scala	3
core/src/main/scala/kafka/common/OffsetAndMetadata.scala	27
core/src/main/scala/kafka/common/LogCleaningAbortedException.scala	3
core/src/main/scala/kafka/common/ThreadShutdownException.scala	3
core/src/main/scala/kafka/common/IndexOffsetOverflowException.scala	4
core/src/main/scala/kafka/common/UnknownCodecException.scala	4
core/src/main/scala/kafka/common/StateChangeFailedException.scala	5
core/src/main/scala/kafka/common/MessageFormatter.scala	4
core/src/main/scala/kafka/common/Config.scala	16
core/src/main/scala/kafka/common/MessageReader.scala	9
core/src/main/scala/kafka/common/GenerateBrokerIdException.scala	6
core/src/main/scala/kafka/common/RecordValidationException.scala	7
core/src/main/scala/kafka/common/UnexpectedAppendOffsetException.scala	5
core/src/main/scala/kafka/common/InconsistentBrokerIdException.scala	6
core/src/main/scala/kafka/common/InconsistentBrokerMetadataException.scala	6
core/src/main/scala/kafka/common/LongRef.scala	30
core/src/main/scala/kafka/common/KafkaException.scala	5
core/src/main/scala/kafka/common/BrokerEndPointNotAvailableException.scala	4
core/src/main/scala/kafka/common/ClientIdAndTopic.scala	9
core/src/main/scala/kafka/common/ZkNodeChangeNotificationListener.scala	99
core/src/main/scala/kafka/common/AdminCommandFailedException.scala	5
core/src/main/scala/kafka/common/ClientIdAndBroker.scala	9
core/src/main/scala/kafka/common/InconsistentClusterIdException.scala	6
core/src/main/scala/kafka/common/NoEpochForPartitionException.scala	4
core/src/main/scala/kafka/common/LogSegmentOffsetOverflowException.scala	5
core/src/main/scala/kafka/api/LeaderAndIsr.scala	26
core/src/main/scala/kafka/api/ApiVersion.scala	252
core/src/main/scala/kafka/api/Request.scala	16
core/src/main/scala/kafka/api/package.scala	27
core/src/main/scala/kafka/api/ApiUtils.scala	39
core/src/main/scala/kafka/log/LogConfig.scala	301
core/src/main/scala/kafka/log/TransactionIndex.scala	168
core/src/main/scala/kafka/log/LogCleaner.scala	717
core/src/main/scala/kafka/log/LogCleanerManager.scala	392
core/src/main/scala/kafka/log/Log.scala	1638
core/src/main/scala/kafka/log/IndexEntry.scala	17
core/src/main/scala/kafka/log/AbstractIndex.scala	200
core/src/main/scala/kafka/log/LogValidator.scala	412
core/src/main/scala/kafka/log/CleanerConfig.scala	11
core/src/main/scala/kafka/log/ProducerStateManager.scala	516
core/src/main/scala/kafka/log/CorruptIndexException.scala	2
core/src/main/scala/kafka/log/OffsetIndex.scala	107
core/src/main/scala/kafka/log/LazyIndex.scala	89
core/src/main/scala/kafka/log/TimeIndex.scala	117
core/src/main/scala/kafka/log/LogSegment.scala	400
core/src/main/scala/kafka/log/OffsetMap.scala	99
core/src/main/scala/kafka/log/LogManager.scala	840
core/src/main/scala/kafka/consumer/BaseConsumerRecord.scala	14
streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java	115
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java	335
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals/TestDriverProducer.java	23
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java	762
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/KeyValueStoreFacade.java	61
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/WindowStoreFacade.java	71
streams/test-utils/src/main/java/org/apache/kafka/streams/TestOutputTopic.java	91
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala	132
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Materialized.scala	23
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/CogroupedKStream.scala	16
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedCogroupedKStream.scala	10
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedKStream.scala	35
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Repartitioned.scala	15
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedTable.scala	24
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Suppressed.scala	28
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala	76
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Produced.scala	11
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/StreamJoined.scala	23
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedKStream.scala	32
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Consumed.scala	20
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/package.scala	11
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedCogroupedKStream.scala	10
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Grouped.scala	9
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedStream.scala	42
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Joined.scala	14
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/serialization/Serdes.scala	63
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/ImplicitConversions.scala	60
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/package.scala	8
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionConversions.scala	52
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala	52
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionsCompatConversions.scala	89
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala	48
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java	40
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	49
streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java	36
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java	66
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonTimestampExtractor.java	19
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java	158
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java	103
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java	110
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java	66
streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java	61
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java	840
streams/src/main/java/org/apache/kafka/streams/Topology.java	309
streams/src/main/java/org/apache/kafka/streams/LagInfo.java	43
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Grouped.java	45
streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Printed.java	52
streams/src/main/java/org/apache/kafka/streams/kstream/Window.java	59
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java	131
streams/src/main/java/org/apache/kafka/streams/kstream/Serialized.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java	56
streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java	13
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java	83
streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java	163
streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java	38
streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java	35
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java	136
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java	20
streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Consumed.java	90
streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/NamedOperation.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java	43
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapter.java	40
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java	108
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java	119
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoin.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionTupleForwarder.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java	56
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMap.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValues.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedKeyValueStoreMaterializer.java	33
streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullChangeSerde.java	52
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java	157
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java	128
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableSerializer.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/Change.java	30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKey.java	31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerde.java	99
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolverJoinProcessorSupplier.java	70
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper.java	67
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchema.java	68
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionProcessorSupplier.java	80
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionSendProcessorSupplier.java	125
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java	37
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionJoinForeignProcessorSupplier.java	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java	118
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedSerializer.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedInternal.java	17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableProcessorSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java	181
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionCacheFlushListener.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java	190
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedDeserializer.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMaterializedValueGetterSupplier.java	31
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java	201
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java	136
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImpl.java	117
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java	947
streams/src/main/java/org/apache/kafka/streams/kstream/internals/StreamJoinedInternal.java	30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java	67
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java	132
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphNode.java	99
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java	66
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamTableJoinNode.java	35
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSinkNode.java	44
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java	84
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GroupedTableOperationRepartitionNode.java	89
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNode.java	50
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java	174
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseRepartitionNode.java	108
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamToTableNode.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java	55
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StateStoreNode.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GlobalStoreNode.java	46
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamStreamJoinNode.java	128
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java	75
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorGraphNode.java	27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GraphGraceSearchUtil.java	65
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseJoinProcessorNode.java	54
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java	211
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetterSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java	386
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalNameProvider.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMapValues.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java	95
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedCacheFlushListener.java	32
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggProcessorSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java	50
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PassThrough.java	16
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedTupleForwarder.java	34
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java	115
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMap.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoinValueGetterSupplier.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinedInternal.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java	79
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFilter.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSourceValueGetterSupplier.java	30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java	167
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ProducedInternal.java	21
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintedInternal.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java	220
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/TimeDefinitions.java	45
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/StrictBufferConfigImpl.java	94
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/NamedSuppressed.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorSupplier.java	172
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/EagerBufferConfigImpl.java	78
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/BufferConfigInternal.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/FinalResultsSuppressionBuilder.java	53
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/BufferFullStrategy.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/SuppressedInternal.java	75
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindow.java	19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowingDefaults.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedStreamPartitioner.java	16
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamJoinWindow.java	32
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java	86
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintForeachAction.java	36
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java	181
streams/src/main/java/org/apache/kafka/streams/kstream/internals/RepartitionedInternal.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindow.java	15
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SerializedInternal.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java	116
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoin.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ConsumedInternal.java	41
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java	107
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableDeserializer.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetter.java	8
streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullTimeWindowedSerde.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java	123
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GlobalKTableImpl.java	18
streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.java	52
streams/src/main/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindow.java	15
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java	116
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java	218
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java	87
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java	113
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransformValues.java	48
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPeek.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java	136
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java	1159
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamBranch.java	30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java	101
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java	100
streams/src/main/java/org/apache/kafka/streams/kstream/internals/NamedInternal.java	48
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPrint.java	27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java	115
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransform.java	48
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java	349
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java	178
streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java	8
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java	53
streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java	62
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java	82
streams/src/main/java/org/apache/kafka/streams/kstream/Named.java	47
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java	35
streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializer.java	46
streams/src/main/java/org/apache/kafka/streams/kstream/Materialized.java	98
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapperWithKey.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/Suppressed.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java	140
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java	64
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java	84
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java	36
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java	56
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java	52
streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java	73
streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java	14
streams/src/main/java/org/apache/kafka/streams/processor/AbstractProcessor.java	16
streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java	6
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java	4
streams/src/main/java/org/apache/kafka/streams/processor/DefaultPartitionGrouper.java	51
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java	44
streams/src/main/java/org/apache/kafka/streams/processor/RecordContext.java	9
streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java	10
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java	40
streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java	8
streams/src/main/java/org/apache/kafka/streams/processor/To.java	44
streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java	20
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreListener.java	15
streams/src/main/java/org/apache/kafka/streams/processor/Cancellable.java	5
streams/src/main/java/org/apache/kafka/streams/processor/StreamPartitioner.java	6
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRegister.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java	225
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java	420
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java	330
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java	789
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java	282
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java	291
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java	33
streams/src/main/java/org/apache/kafka/streams/processor/internals/ToInternal.java	19
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java	49
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java	11
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java	40
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java	248
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java	210
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java	610
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java	229
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java	115
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java	207
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java	725
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java	65
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java	917
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalApiProcessorContext.java	36
streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java	32
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java	149
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java	19
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java	295
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java	1614
streams/src/main/java/org/apache/kafka/streams/processor/internals/ThreadStateTransitionValidator.java	4
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java	121
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java	168
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java	71
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java	257
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java	1166
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java	315
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySet.java	55
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java	174
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/CopartitionedTopicsEnforcer.java	135
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.java	265
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignor.java	11
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/FallbackPriorTaskAssignor.java	20
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java	407
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java	310
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorError.java	12
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java	250
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProtocolVersions.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java	205
streams/src/main/java/org/apache/kafka/streams/processor/internals/StaticTopicNameExtractor.java	32
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java	93
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java	478
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java	367
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java	280
streams/src/main/java/org/apache/kafka/streams/processor/internals/QuickUnion.java	39
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java	68
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamPartitioner.java	20
streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.java	66
streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java	123
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java	6
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultKafkaClientSupplier.java	38
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java	22
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskAction.java	5
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManager.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java	182
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java	90
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestoreCallbackAdapter.java	31
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorAdapter.java	37
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java	227
streams/src/main/java/org/apache/kafka/streams/processor/internals/RestoringTasks.java	5
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java	83
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java	126
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java	156
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java	105
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordBatchingStateRestoreCallback.java	12
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java	174
streams/src/main/java/org/apache/kafka/streams/processor/internals/StampedRecord.java	30
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java	218
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java	105
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java	70
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java	75
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicProperties.java	20
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java	11
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java	57
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationQueue.java	38
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java	774
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextAdapter.java	177
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationSchedule.java	69
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextReverseAdapter.java	188
streams/src/main/java/org/apache/kafka/streams/processor/Processor.java	7
streams/src/main/java/org/apache/kafka/streams/processor/PartitionGrouper.java	9
streams/src/main/java/org/apache/kafka/streams/processor/TopicNameExtractor.java	4
streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java	10
streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java	18
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java	40
streams/src/main/java/org/apache/kafka/streams/processor/api/Processor.java	10
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorSupplier.java	7
streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java	66
streams/src/main/java/org/apache/kafka/streams/processor/PunctuationType.java	6
streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java	15
streams/src/main/java/org/apache/kafka/streams/processor/Punctuator.java	5
streams/src/main/java/org/apache/kafka/streams/processor/ConnectedStoreProvider.java	14
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestamp.java	16
streams/src/main/java/org/apache/kafka/streams/processor/ThreadMetadata.java	99
streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java	43
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java	14
streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java	80
streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java	11
streams/src/main/java/org/apache/kafka/streams/state/WindowStoreIterator.java	8
streams/src/main/java/org/apache/kafka/streams/state/TimestampedKeyValueStore.java	2
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java	9
streams/src/main/java/org/apache/kafka/streams/state/StateSerdes.java	92
streams/src/main/java/org/apache/kafka/streams/state/Stores.java	216
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java	84
streams/src/main/java/org/apache/kafka/streams/state/ValueAndTimestamp.java	46
streams/src/main/java/org/apache/kafka/streams/state/WindowBytesStoreSupplier.java	10
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java	28
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java	123
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java	28
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializer.java	85
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTrigger.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetrics.java	67
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java	532
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java	734
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java	422
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java	151
streams/src/main/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIterator.java	57
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedSegmentedBytesStore.java	10
streams/src/main/java/org/apache/kafka/streams/state/internals/BufferValue.java	120
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbSessionBytesStoreSupplier.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java	310
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java	358
streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverters.java	37
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerde.java	35
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeKeyValueIterator.java	41
streams/src/main/java/org/apache/kafka/streams/state/internals/OffsetCheckpoint.java	132
streams/src/main/java/org/apache/kafka/streams/state/internals/CachedStateStore.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java	86
streams/src/main/java/org/apache/kafka/streams/state/internals/ReadOnlyKeyValueStoreFacade.java	37
streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java	7
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java	169
streams/src/main/java/org/apache/kafka/streams/state/internals/Maybe.java	51
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java	287
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java	239
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java	473
streams/src/main/java/org/apache/kafka/streams/state/internals/StateStoreProvider.java	8
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueIteratorFacade.java	28
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java	225
streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java	60
streams/src/main/java/org/apache/kafka/streams/state/internals/NextIteratorFunction.java	5
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java	259
streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java	367
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionBytesStoreSupplier.java	33
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java	122
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java	487
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java	149
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java	421
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java	119
streams/src/main/java/org/apache/kafka/streams/state/internals/FilteredCacheIterator.java	68
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java	89
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.java	27
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java	54
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java	56
streams/src/main/java/org/apache/kafka/streams/state/internals/ContextualRecord.java	51
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java	106
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java	48
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java	181
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java	98
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java	31
streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java	15
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStore.java	36
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegment.java	45
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterator.java	135
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractStoreBuilder.java	63
streams/src/main/java/org/apache/kafka/streams/state/internals/OrderedBytes.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java	82
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilder.java	41
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegments.java	34
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java	483
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java	51
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java	73
streams/src/main/java/org/apache/kafka/streams/state/internals/ExceptionUtils.java	26
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java	51
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIterator.java	36
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java	98
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreKeyValueIterator.java	47
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueByteStoreAdapter.java	94
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStore.java	51
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java	10
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java	81
streams/src/main/java/org/apache/kafka/streams/state/internals/BatchWritingStore.java	9
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java	118
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegments.java	34
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java	68
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegment.java	45
streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverter.java	5
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreIterator.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java	307
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueIterators.java	37
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java	76
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedCacheFunction.java	56
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowBytesStoreSupplier.java	65
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheSessionStoreIterator.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java	60
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java	190
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractSegments.java	187
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedWindowStore.java	9
streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFunction.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBuffer.java	54
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBRangeIterator.java	55
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesStore.java	20
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java	1111
streams/src/main/java/org/apache/kafka/streams/state/internals/BlockBasedTableConfigWithAccessibleCache.java	14
streams/src/main/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProvider.java	33
streams/src/main/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreFacade.java	109
streams/src/main/java/org/apache/kafka/streams/state/internals/HasNextCondition.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java	259
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java	47
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java	231
streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java	297
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampDeserializer.java	54
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java	139
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueBytesStore.java	19
streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFlushListener.java	4
streams/src/main/java/org/apache/kafka/streams/state/internals/BufferKey.java	45
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueIteratorAdapter.java	27
streams/src/main/java/org/apache/kafka/streams/state/internals/PeekingKeyValueIterator.java	6
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java	25
streams/src/main/java/org/apache/kafka/streams/state/StoreSupplier.java	7
streams/src/main/java/org/apache/kafka/streams/state/TimestampedWindowStore.java	3
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/KeyValueBytesStoreSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/state/HostInfo.java	63
streams/src/main/java/org/apache/kafka/streams/state/StoreBuilder.java	13
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java	6
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java	102
streams/src/main/java/org/apache/kafka/streams/state/TimestampedBytesStore.java	15
streams/src/main/java/org/apache/kafka/streams/state/SessionBytesStoreSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/state/RocksDBConfigSetter.java	12
streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java	37
streams/src/main/java/org/apache/kafka/streams/internals/metrics/ClientMetrics.java	97
streams/src/main/java/org/apache/kafka/streams/internals/ApiUtils.java	34
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java	195
streams/src/main/java/org/apache/kafka/streams/StoreQueryParameters.java	61
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java	713
streams/src/main/java/org/apache/kafka/streams/errors/UnknownStateStoreException.java	10
streams/src/main/java/org/apache/kafka/streams/errors/TaskCorruptedException.java	21
streams/src/main/java/org/apache/kafka/streams/errors/MissingSourceTopicException.java	7
streams/src/main/java/org/apache/kafka/streams/errors/TaskMigratedException.java	10
streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java	22
streams/src/main/java/org/apache/kafka/streams/errors/DeserializationExceptionHandler.java	19
streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java	22
streams/src/main/java/org/apache/kafka/streams/errors/LockException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/StateStoreNotAvailableException.java	10
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStorePartitionException.java	11
streams/src/main/java/org/apache/kafka/streams/errors/TopologyException.java	14
streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java	14
streams/src/main/java/org/apache/kafka/streams/errors/StreamsRebalancingException.java	10
streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java	13
streams/src/main/java/org/apache/kafka/streams/errors/ProductionExceptionHandler.java	18
streams/src/main/java/org/apache/kafka/streams/errors/TaskAssignmentException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/StateStoreMigratedException.java	10
streams/src/main/java/org/apache/kafka/streams/errors/StreamsNotStartedException.java	12
streams/src/main/java/org/apache/kafka/streams/KafkaClientSupplier.java	24
streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java	60
streams/src/main/java/org/apache/kafka/streams/KeyValue.java	32
generator/src/main/java/org/apache/kafka/message/MessageSpec.java	83
generator/src/main/java/org/apache/kafka/message/MessageClassGenerator.java	6
generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java	373
generator/src/main/java/org/apache/kafka/message/VersionConditional.java	159
generator/src/main/java/org/apache/kafka/message/HeaderGenerator.java	63
generator/src/main/java/org/apache/kafka/message/MessageSpecType.java	12
generator/src/main/java/org/apache/kafka/message/ApiMessageTypeGenerator.java	295
generator/src/main/java/org/apache/kafka/message/EntityType.java	35
generator/src/main/java/org/apache/kafka/message/FieldType.java	332
generator/src/main/java/org/apache/kafka/message/ClauseGenerator.java	4
generator/src/main/java/org/apache/kafka/message/IsNullConditional.java	94
generator/src/main/java/org/apache/kafka/message/MessageGenerator.java	257
generator/src/main/java/org/apache/kafka/message/StructSpec.java	67
generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java	1856
generator/src/main/java/org/apache/kafka/message/SchemaGenerator.java	274
generator/src/main/java/org/apache/kafka/message/Versions.java	120
generator/src/main/java/org/apache/kafka/message/FieldSpec.java	496
generator/src/main/java/org/apache/kafka/message/CodeBuffer.java	53
generator/src/main/java/org/apache/kafka/message/Target.java	67
generator/src/main/java/org/apache/kafka/message/TypeClassGenerator.java	8
generator/src/main/java/org/apache/kafka/message/StructRegistry.java	129
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	151
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/cache/LRUCacheBenchmark.java	47
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java	262
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/CheckpointBench.java	145
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/TopicBenchmark.java	31
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchRequestBenchmark.java	94
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchResponseBenchmark.java	75
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetchsession/FetchSessionBenchmark.java	87
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/consumer/SubscriptionStateBenchmark.java	69
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java	147
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java	146
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/MetadataRequestBenchmark.java	175
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/AclAuthorizerBenchmark.java	127
examples/src/main/java/kafka/examples/KafkaProperties.java	7
examples/src/main/java/kafka/examples/Consumer.java	70
examples/src/main/java/kafka/examples/Producer.java	94
examples/src/main/java/kafka/examples/KafkaConsumerProducerDemo.java	20
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java	127
examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java	107
log4j-appender/src/main/java/org/apache/kafka/log4jappender/KafkaLog4jAppender.java	292
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java	183
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkConnector.java	49
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkTask.java	67
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java	64
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkTask.java	53
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/MockSinkConnector.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/MockSourceConnector.java	51
connect/runtime/src/main/java/org/apache/kafka/connect/tools/TransformationDoc.java	63
connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java	135
connect/runtime/src/main/java/org/apache/kafka/connect/tools/PredicateDoc.java	55
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkConnector.java	41
connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockConnector.java	71
connect/runtime/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java	103
connect/runtime/src/main/java/org/apache/kafka/connect/tools/SchemaSourceConnector.java	41
connect/runtime/src/main/java/org/apache/kafka/connect/util/LoggingContext.java	81
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConvertingFutureCallback.java	87
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreationGroup.java	87
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java	50
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java	229
connect/runtime/src/main/java/org/apache/kafka/connect/util/Table.java	42
connect/runtime/src/main/java/org/apache/kafka/connect/util/ConnectUtils.java	66
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/FutureCallback.java	13
connect/runtime/src/main/java/org/apache/kafka/connect/util/Callback.java	4
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreation.java	63
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java	336
connect/runtime/src/main/java/org/apache/kafka/connect/util/SinkUtils.java	7
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java	411
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderRequest.java	4
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java	568
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicStatus.java	57
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java	537
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java	352
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneConfig.java	19
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/WorkerCoordinator.java	457
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ExtendedWorkerState.java	19
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java	209
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerRebalanceListener.java	7
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/ConnectProtocolCompatibility.java	70
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java	1446
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java	383
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectAssignor.java	10
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ClusterConfigState.java	172
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeConnectProtocol.java	124
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ExtendedAssignment.java	189
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/NotLeaderException.java	6
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java	181
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java	545
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/EagerAssignor.java	127
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java	311
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskStatus.java	18
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTaskContext.java	25
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java	76
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/health/ConnectClusterDetailsImpl.java	12
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/health/ConnectClusterStateImpl.java	86
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java	130
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java	414
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractStatus.java	71
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/StateTracker.java	96
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java	125
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java	355
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java	843
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/PredicatedTransformation.java	50
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/CloseableConnectorContext.java	7
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java	221
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java	355
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java	405
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java	268
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	76
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginType.java	40
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java	50
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java	44
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SessionKey.java	31
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TargetState.java	5
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicCreationConfig.java	112
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderConnectorContext.java	38
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java	79
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	688
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorStatus.java	17
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfigTransformer.java	77
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java	441
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/Stage.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ToleranceType.java	9
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/Operation.java	4
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorReporter.java	8
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ErrorHandlingMetrics.java	68
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/DeadLetterQueueReporter.java	155
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/LogReporter.java	40
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporter.java	110
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java	185
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ProcessingContext.java	136
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java	54
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTaskContext.java	128
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java	23
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java	74
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/ConnectRestConfigurable.java	96
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java	351
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/util/SSLUtils.java	96
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java	92
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResource.java	128
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java	337
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/ConnectRestExtensionContextImpl.java	23
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/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/entities/TaskInfo.java	33
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/ConnectorPluginInfo.java	62
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ServerInfo.java	32
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/CreateConnectorRequest.java	34
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorInfo.java	53
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/ConnectorStateInfo.java	101
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/ActiveTopicsInfo.java	20
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/ConfigInfos.java	69
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java	131
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignature.java	99
connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverterConfig.java	13
connect/runtime/src/main/java/org/apache/kafka/connect/converters/LongConverter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/converters/ShortConverter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverter.java	81
connect/runtime/src/main/java/org/apache/kafka/connect/converters/FloatConverter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/converters/IntegerConverter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/converters/DoubleConverter.java	11
connect/runtime/src/main/java/org/apache/kafka/connect/converters/ByteArrayConverter.java	45
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java	90
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java	90
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReaderImpl.java	119
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java	192
connect/runtime/src/main/java/org/apache/kafka/connect/storage/FileOffsetBackingStore.java	70
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java	512
connect/runtime/src/main/java/org/apache/kafka/connect/storage/StatusBackingStore.java	26
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetUtils.java	31
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java	100
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryOffsetBackingStore.java	78
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java	130
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java	102
connect/runtime/src/main/java/org/apache/kafka/connect/storage/CloseableOffsetStorageReader.java	8
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetBackingStore.java	14
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConfigBackingStore.java	31
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java	540
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/PrincipalConnectorClientConfigOverridePolicy.java	29
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/AllConnectorClientConfigOverridePolicy.java	20
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/NoneConnectorClientConfigOverridePolicy.java	20
connect/runtime/src/main/java/org/apache/kafka/connect/connector/policy/AbstractConnectorClientConfigOverridePolicy.java	30
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/PropertyFileLoginModule.java	113
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/BasicAuthSecurityRestExtension.java	27
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java	110
connect/json/src/main/java/org/apache/kafka/connect/json/DecimalFormat.java	5
connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java	34
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java	32
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java	656
connect/json/src/main/java/org/apache/kafka/connect/json/JsonSchema.java	58
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java	63
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.java	48
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKey.java	38
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/RecordIsTombstone.java	26
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java	69
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/SimpleConfig.java	9
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/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/Flatten.java	218
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java	85
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java	101
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java	173
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java	357
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java	162
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java	211
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java	383
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/RegexRouter.java	46
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ValueToKey.java	79
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Filter.java	24
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java	80
connect/api/src/main/java/org/apache/kafka/connect/util/ConnectorUtils.java	23
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectClusterDetails.java	4
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorType.java	11
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java	61
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectClusterState.java	13
connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java	42
connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java	36
connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorState.java	14
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnectorContext.java	6
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java	8
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java	25
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java	7
connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java	84
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java	17
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnectorContext.java	4
connect/api/src/main/java/org/apache/kafka/connect/sink/ErrantRecordReporter.java	6
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java	37
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java	9
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java	64
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/HeaderConverter.java	12
connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java	16
connect/api/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReader.java	7
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/StringConverterConfig.java	27
connect/api/src/main/java/org/apache/kafka/connect/components/Versioned.java	4
connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/Predicate.java	10
connect/api/src/main/java/org/apache/kafka/connect/transforms/Transformation.java	11
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectRecord.java	106
connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java	39
connect/api/src/main/java/org/apache/kafka/connect/connector/Task.java	7
connect/api/src/main/java/org/apache/kafka/connect/connector/ConnectorContext.java	5
connect/api/src/main/java/org/apache/kafka/connect/connector/policy/ConnectorClientConfigRequest.java	41
connect/api/src/main/java/org/apache/kafka/connect/connector/policy/ConnectorClientConfigOverridePolicy.java	7
connect/api/src/main/java/org/apache/kafka/connect/errors/AlreadyExistsException.java	12
connect/api/src/main/java/org/apache/kafka/connect/errors/DataException.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/IllegalWorkerStateException.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/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/data/Values.java	931
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaBuilder.java	228
connect/api/src/main/java/org/apache/kafka/connect/data/Timestamp.java	21
connect/api/src/main/java/org/apache/kafka/connect/data/Schema.java	72
connect/api/src/main/java/org/apache/kafka/connect/data/Decimal.java	35
connect/api/src/main/java/org/apache/kafka/connect/data/Time.java	33
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaProjector.java	150
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java	239
connect/api/src/main/java/org/apache/kafka/connect/data/Field.java	42
connect/api/src/main/java/org/apache/kafka/connect/data/SchemaAndValue.java	36
connect/api/src/main/java/org/apache/kafka/connect/data/Date.java	32
connect/api/src/main/java/org/apache/kafka/connect/data/Struct.java	138
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java	404
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeader.java	64
connect/api/src/main/java/org/apache/kafka/connect/header/Headers.java	44
connect/api/src/main/java/org/apache/kafka/connect/header/Header.java	9
connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtensionContext.java	7
connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtension.java	9
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClient.java	168
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java	82
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/DefaultReplicationPolicy.java	43
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/RemoteClusterUtils.java	41
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/SourceAndTarget.java	27
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Heartbeat.java	105
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/Checkpoint.java	140
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java	20
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorUtils.java	78
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceTask.java	241
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/Scheduler.java	85
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultGroupFilter.java	58
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/ConfigPropertyFilter.java	12
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java	252
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/HeartbeatFormatter.java	11
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/CheckpointFormatter.java	11
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/formatters/OffsetSyncFormatter.java	11
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java	53
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultTopicFilter.java	58
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/DefaultConfigPropertyFilter.java	48
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMetrics.java	159
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java	529
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatConnector.java	50
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatTask.java	56
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java	223
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorTaskConfig.java	50
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/TopicFilter.java	12
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java	172
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java	125
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/GroupFilter.java	12
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java	350
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSync.java	83