Path	Lines of Code
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/ClientRebootstrapTest.java	205
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/ClientsTestUtils.java	158
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/MetadataVersionIntegrationTest.java	62
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/MetricsDuringTopicCreationDeletionTest.java	104
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/TransactionsExpirationTest.java	245
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/TransactionsWithMaxInFlightOneTest.java	99
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/AdminFenceProducersTest.java	96
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/ClientTelemetryTest.java	148
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DeleteTopicTest.java	306
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DescribeAuthorizedOperationsTest.java	190
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/ListOffsetsIntegrationTest.java	208
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/RackAwareAutoTopicCreationTest.java	105
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/StaticBrokerConfigTest.java	80
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerIntegrationTest.java	186
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerTopicCreationTest.java	93
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerCallbackTest.java	235
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerFetchTest.java	386
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java	2349
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/producer/ProducerCompressionTest.java	131
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/producer/ProducerFailureHandlingTest.java	206
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/producer/ProducerIdExpirationTest.java	205
clients/clients-integration-tests/src/test/java/org/apache/kafka/server/quota/CustomQuotaCallbackTest.java	133
clients/clients-integration-tests/src/test/resources/log4j2.yaml	20
clients/src/test/java/org/apache/kafka/clients/AddressChangeHostResolver.java	26
clients/src/test/java/org/apache/kafka/clients/ApiVersionsTest.java	40
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java	165
clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java	329
clients/src/test/java/org/apache/kafka/clients/CommonClientConfigsTest.java	121
clients/src/test/java/org/apache/kafka/clients/FetchSessionHandlerTest.java	618
clients/src/test/java/org/apache/kafka/clients/InFlightRequestsTest.java	86
clients/src/test/java/org/apache/kafka/clients/MetadataSnapshotTest.java	176
clients/src/test/java/org/apache/kafka/clients/MetadataTest.java	932
clients/src/test/java/org/apache/kafka/clients/MockClient.java	639
clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java	1104
clients/src/test/java/org/apache/kafka/clients/NodeApiVersionsTest.java	162
clients/src/test/java/org/apache/kafka/clients/admin/AdminClientConfigTest.java	25
clients/src/test/java/org/apache/kafka/clients/admin/AdminClientTestUtils.java	110
clients/src/test/java/org/apache/kafka/clients/admin/AdminClientUnitTestEnv.java	88
clients/src/test/java/org/apache/kafka/clients/admin/ConfigTest.java	70
clients/src/test/java/org/apache/kafka/clients/admin/ConsumerGroupDescriptionTest.java	20
clients/src/test/java/org/apache/kafka/clients/admin/ConsumerGroupListingTest.java	18
clients/src/test/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResultTest.java	84
clients/src/test/java/org/apache/kafka/clients/admin/DeleteTopicsResultTest.java	38
clients/src/test/java/org/apache/kafka/clients/admin/DescribeTopicsResultTest.java	22
clients/src/test/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResultTest.java	89
clients/src/test/java/org/apache/kafka/clients/admin/EndpointTypeTest.java	24
clients/src/test/java/org/apache/kafka/clients/admin/FakeForwardingAdmin.java	7
clients/src/test/java/org/apache/kafka/clients/admin/GroupListingTest.java	22
clients/src/test/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptionsTest.java	15
clients/src/test/java/org/apache/kafka/clients/admin/ListTransactionsResultTest.java	78
clients/src/test/java/org/apache/kafka/clients/admin/MemberDescriptionTest.java	117
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java	1358
clients/src/test/java/org/apache/kafka/clients/admin/NewTopicTest.java	142
clients/src/test/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptionsTest.java	15
clients/src/test/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResultTest.java	85
clients/src/test/java/org/apache/kafka/clients/admin/ScramMechanismTest.java	13
clients/src/test/java/org/apache/kafka/clients/admin/TopicCollectionTest.java	20
clients/src/test/java/org/apache/kafka/clients/admin/internals/AbortTransactionHandlerTest.java	174
clients/src/test/java/org/apache/kafka/clients/admin/internals/AdminApiDriverTest.java	703
clients/src/test/java/org/apache/kafka/clients/admin/internals/AdminBootstrapAddressesTest.java	59
clients/src/test/java/org/apache/kafka/clients/admin/internals/AdminFetchMetricsManagerTest.java	125
clients/src/test/java/org/apache/kafka/clients/admin/internals/AdminMetadataManagerTest.java	118
clients/src/test/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategyIntegrationTest.java	188
clients/src/test/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategyTest.java	86
clients/src/test/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandlerTest.java	152
clients/src/test/java/org/apache/kafka/clients/admin/internals/CoordinatorStrategyTest.java	231
clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandlerTest.java	170
clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupsHandlerTest.java	7
clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteGroupsHandlerTest.java	101
clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteRecordsHandlerTest.java	242
clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteShareGroupsHandlerTest.java	7
clients/src/test/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandlerTest.java	370
clients/src/test/java/org/apache/kafka/clients/admin/internals/DescribeProducersHandlerTest.java	267
clients/src/test/java/org/apache/kafka/clients/admin/internals/DescribeTransactionsHandlerTest.java	181
clients/src/test/java/org/apache/kafka/clients/admin/internals/FenceProducersHandlerTest.java	119
clients/src/test/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandlerTest.java	367
clients/src/test/java/org/apache/kafka/clients/admin/internals/ListOffsetsHandlerTest.java	273
clients/src/test/java/org/apache/kafka/clients/admin/internals/ListTransactionsHandlerTest.java	207
clients/src/test/java/org/apache/kafka/clients/admin/internals/PartitionLeaderStrategyIntegrationTest.java	342
clients/src/test/java/org/apache/kafka/clients/admin/internals/PartitionLeaderStrategyTest.java	246
clients/src/test/java/org/apache/kafka/clients/admin/internals/RemoveMembersFromConsumerGroupHandlerTest.java	143
clients/src/test/java/org/apache/kafka/clients/consumer/CloseOptionsTest.java	28
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerConfigTest.java	206
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadataTest.java	55
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerPartitionAssignorTest.java	115
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerRecordTest.java	75
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerRecordsTest.java	161
clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java	197
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java	2842
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaShareConsumerMetricsTest.java	311
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaShareConsumerTest.java	321
clients/src/test/java/org/apache/kafka/clients/consumer/MockConsumerTest.java	181
clients/src/test/java/org/apache/kafka/clients/consumer/MockShareConsumerTest.java	30
clients/src/test/java/org/apache/kafka/clients/consumer/OffsetAndMetadataTest.java	36
clients/src/test/java/org/apache/kafka/clients/consumer/RangeAssignorTest.java	468
clients/src/test/java/org/apache/kafka/clients/consumer/RoundRobinAssignorTest.java	259
clients/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerConfigTest.java	30
clients/src/test/java/org/apache/kafka/clients/consumer/StickyAssignorTest.java	316
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java	1380
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignorTest.java	249
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java	1229
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AcknowledgementCommitCallbackHandlerTest.java	137
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AcknowledgementsTest.java	426
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ApplicationEventHandlerTest.java	43
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java	1782
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AutoOffsetResetStrategyTest.java	88
clients/src/test/java/org/apache/kafka/clients/consumer/internals/BackgroundEventHandlerTest.java	40
clients/src/test/java/org/apache/kafka/clients/consumer/internals/BaseHeartbeatThreadTest.java	38
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CommitRequestManagerTest.java	1329
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CompletedFetchTest.java	249
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java	3188
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManagerTest.java	947
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptorsTest.java	149
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManagerTest.java	2193
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerMetadataTest.java	300
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClientTest.java	332
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThreadTest.java	238
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java	292
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CooperativeConsumerCoordinatorTest.java	7
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManagerTest.java	210
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CounterConsumerRebalanceListener.java	60
clients/src/test/java/org/apache/kafka/clients/consumer/internals/EagerConsumerCoordinatorTest.java	7
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchBufferTest.java	138
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchCollectorTest.java	765
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchConfigTest.java	32
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchMetricsManagerTest.java	283
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchRequestManagerTest.java	3179
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java	2962
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestStateTest.java	101
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatTest.java	86
clients/src/test/java/org/apache/kafka/clients/consumer/internals/KafkaConsumerMetricsTest.java	41
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MockPartitionAssignor.java	42
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MockRebalanceListener.java	27
clients/src/test/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegateTest.java	262
clients/src/test/java/org/apache/kafka/clients/consumer/internals/OffsetCommitCallbackInvokerTest.java	104
clients/src/test/java/org/apache/kafka/clients/consumer/internals/OffsetFetcherTest.java	1340
clients/src/test/java/org/apache/kafka/clients/consumer/internals/OffsetForLeaderEpochClientTest.java	133
clients/src/test/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManagerTest.java	884
clients/src/test/java/org/apache/kafka/clients/consumer/internals/RequestFutureTest.java	176
clients/src/test/java/org/apache/kafka/clients/consumer/internals/RequestManagersTest.java	91
clients/src/test/java/org/apache/kafka/clients/consumer/internals/RequestStateTest.java	52
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareAcknowledgementModeTest.java	41
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareCompletedFetchTest.java	380
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManagerTest.java	2059
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImplTest.java	605
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareFetchBufferTest.java	125
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareFetchCollectorTest.java	262
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareFetchMetricsManagerTest.java	96
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareHeartbeatRequestManagerTest.java	613
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareMembershipManagerTest.java	1194
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandlerTest.java	376
clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManagerTest.java	1440
clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManagerTest.java	1895
clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceDataTest.java	379
clients/src/test/java/org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java	766
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ThrowOnAssignmentAssignor.java	23
clients/src/test/java/org/apache/kafka/clients/consumer/internals/TimedRequestStateTest.java	69
clients/src/test/java/org/apache/kafka/clients/consumer/internals/TopicMetadataFetcherTest.java	207
clients/src/test/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManagerTest.java	246
clients/src/test/java/org/apache/kafka/clients/consumer/internals/TopicPartitionComparatorTest.java	33
clients/src/test/java/org/apache/kafka/clients/consumer/internals/WakeupTriggerTest.java	179
clients/src/test/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessorTest.java	555
clients/src/test/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaperTest.java	113
clients/src/test/java/org/apache/kafka/clients/consumer/internals/metrics/AsyncConsumerMetricsTest.java	172
clients/src/test/java/org/apache/kafka/clients/consumer/internals/metrics/HeartbeatMetricsManagerTest.java	32
clients/src/test/java/org/apache/kafka/clients/consumer/internals/metrics/OffsetCommitMetricsManagerTest.java	26
clients/src/test/java/org/apache/kafka/clients/consumer/internals/metrics/RebalanceCallbackMetricsManagerTest.java	30
clients/src/test/java/org/apache/kafka/clients/consumer/internals/metrics/ShareRebalanceMetricsManagerTest.java	25
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java	2440
clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java	621
clients/src/test/java/org/apache/kafka/clients/producer/PreparedTxnStateTest.java	130
clients/src/test/java/org/apache/kafka/clients/producer/ProducerConfigTest.java	131
clients/src/test/java/org/apache/kafka/clients/producer/ProducerRecordTest.java	45
clients/src/test/java/org/apache/kafka/clients/producer/RecordMetadataTest.java	38
clients/src/test/java/org/apache/kafka/clients/producer/RecordSendTest.java	65
clients/src/test/java/org/apache/kafka/clients/producer/RoundRobinPartitionerTest.java	66
clients/src/test/java/org/apache/kafka/clients/producer/internals/BufferPoolTest.java	303
clients/src/test/java/org/apache/kafka/clients/producer/internals/BuiltInPartitionerTest.java	142
clients/src/test/java/org/apache/kafka/clients/producer/internals/FutureRecordMetadataTest.java	50
clients/src/test/java/org/apache/kafka/clients/producer/internals/KafkaProducerMetricsTest.java	72
clients/src/test/java/org/apache/kafka/clients/producer/internals/ProducerBatchTest.java	276
clients/src/test/java/org/apache/kafka/clients/producer/internals/ProducerInterceptorsTest.java	190
clients/src/test/java/org/apache/kafka/clients/producer/internals/ProducerMetadataTest.java	246
clients/src/test/java/org/apache/kafka/clients/producer/internals/ProducerTestUtils.java	24
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java	1268
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java	2889
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java	3336
clients/src/test/java/org/apache/kafka/common/ClusterTest.java	134
clients/src/test/java/org/apache/kafka/common/KafkaFutureTest.java	541
clients/src/test/java/org/apache/kafka/common/PartitionInfoTest.java	20
clients/src/test/java/org/apache/kafka/common/TopicIdPartitionTest.java	51
clients/src/test/java/org/apache/kafka/common/TopicPartitionTest.java	28
clients/src/test/java/org/apache/kafka/common/UuidTest.java	101
clients/src/test/java/org/apache/kafka/common/acl/AclBindingTest.java	112
clients/src/test/java/org/apache/kafka/common/acl/AclOperationTest.java	67
clients/src/test/java/org/apache/kafka/common/acl/AclPermissionTypeTest.java	54
clients/src/test/java/org/apache/kafka/common/acl/ResourcePatternFilterTest.java	133
clients/src/test/java/org/apache/kafka/common/acl/ResourcePatternTest.java	25
clients/src/test/java/org/apache/kafka/common/compress/GzipCompressionTest.java	59
clients/src/test/java/org/apache/kafka/common/compress/Lz4CompressionTest.java	348
clients/src/test/java/org/apache/kafka/common/compress/NoCompressionTest.java	35
clients/src/test/java/org/apache/kafka/common/compress/SnappyCompressionTest.java	34
clients/src/test/java/org/apache/kafka/common/compress/ZstdCompressionTest.java	47
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java	593
clients/src/test/java/org/apache/kafka/common/config/ConfigDefTest.java	640
clients/src/test/java/org/apache/kafka/common/config/ConfigResourceTest.java	24
clients/src/test/java/org/apache/kafka/common/config/ConfigTransformerTest.java	112
clients/src/test/java/org/apache/kafka/common/config/SaslConfigsTest.java	95
clients/src/test/java/org/apache/kafka/common/config/provider/AllowedPathsTest.java	77
clients/src/test/java/org/apache/kafka/common/config/provider/DirectoryConfigProviderTest.java	168
clients/src/test/java/org/apache/kafka/common/config/provider/EnvVarConfigProviderTest.java	82
clients/src/test/java/org/apache/kafka/common/config/provider/FileConfigProviderTest.java	165
clients/src/test/java/org/apache/kafka/common/config/provider/MockFileConfigProvider.java	42
clients/src/test/java/org/apache/kafka/common/config/provider/MockVaultConfigProvider.java	25
clients/src/test/java/org/apache/kafka/common/errors/TransactionExceptionHierarchyTest.java	52
clients/src/test/java/org/apache/kafka/common/feature/FeaturesTest.java	90
clients/src/test/java/org/apache/kafka/common/feature/SupportedVersionRangeTest.java	105
clients/src/test/java/org/apache/kafka/common/header/internals/RecordHeadersTest.java	148
clients/src/test/java/org/apache/kafka/common/internals/IdempotentCloserTest.java	87
clients/src/test/java/org/apache/kafka/common/internals/PartitionStatesTest.java	164
clients/src/test/java/org/apache/kafka/common/internals/PluginTest.java	113
clients/src/test/java/org/apache/kafka/common/internals/SecurityManagerCompatibilityTest.java	174
clients/src/test/java/org/apache/kafka/common/internals/TopicTest.java	75
clients/src/test/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPoolTest.java	126
clients/src/test/java/org/apache/kafka/common/message/ApiMessageTypeTest.java	109
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java	844
clients/src/test/java/org/apache/kafka/common/message/NullableStructMessageTest.java	96
clients/src/test/java/org/apache/kafka/common/message/RecordsSerdeTest.java	53
clients/src/test/java/org/apache/kafka/common/message/SimpleArraysMessageTest.java	31
clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java	303
clients/src/test/java/org/apache/kafka/common/metrics/FakeMetricsReporter.java	15
clients/src/test/java/org/apache/kafka/common/metrics/JmxReporterTest.java	132
clients/src/test/java/org/apache/kafka/common/metrics/KafkaMbeanTest.java	119
clients/src/test/java/org/apache/kafka/common/metrics/KafkaMetricTest.java	26
clients/src/test/java/org/apache/kafka/common/metrics/KafkaMetricsContextTest.java	56
clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java	739
clients/src/test/java/org/apache/kafka/common/metrics/SampleMetrics.java	7
clients/src/test/java/org/apache/kafka/common/metrics/SensorTest.java	268
clients/src/test/java/org/apache/kafka/common/metrics/TokenBucketTest.java	49
clients/src/test/java/org/apache/kafka/common/metrics/internals/IntGaugeSuiteTest.java	71
clients/src/test/java/org/apache/kafka/common/metrics/internals/MetricsUtilsTest.java	18
clients/src/test/java/org/apache/kafka/common/metrics/internals/PluginMetricsImplTest.java	89
clients/src/test/java/org/apache/kafka/common/metrics/stats/FrequenciesTest.java	132
clients/src/test/java/org/apache/kafka/common/metrics/stats/HistogramTest.java	146
clients/src/test/java/org/apache/kafka/common/metrics/stats/MeterTest.java	47
clients/src/test/java/org/apache/kafka/common/metrics/stats/RateTest.java	59
clients/src/test/java/org/apache/kafka/common/metrics/stats/SampledStatTest.java	64
clients/src/test/java/org/apache/kafka/common/network/CertStores.java	114
clients/src/test/java/org/apache/kafka/common/network/ChannelBuildersTest.java	78
clients/src/test/java/org/apache/kafka/common/network/DefaultChannelMetadataRegistry.java	26
clients/src/test/java/org/apache/kafka/common/network/EchoServer.java	108
clients/src/test/java/org/apache/kafka/common/network/KafkaChannelTest.java	79
clients/src/test/java/org/apache/kafka/common/network/NetworkReceiveTest.java	84
clients/src/test/java/org/apache/kafka/common/network/NetworkTestUtils.java	103
clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java	344
clients/src/test/java/org/apache/kafka/common/network/PlaintextSender.java	19
clients/src/test/java/org/apache/kafka/common/network/SaslChannelBuilderTest.java	188
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java	912
clients/src/test/java/org/apache/kafka/common/network/ServerConnectionIdTest.java	137
clients/src/test/java/org/apache/kafka/common/network/SslSelectorTest.java	289
clients/src/test/java/org/apache/kafka/common/network/SslSender.java	54
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java	1180
clients/src/test/java/org/apache/kafka/common/network/SslTransportTls12Tls13Test.java	109
clients/src/test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java	107
clients/src/test/java/org/apache/kafka/common/network/Tls12SelectorTest.java	41
clients/src/test/java/org/apache/kafka/common/network/Tls13SelectorTest.java	57
clients/src/test/java/org/apache/kafka/common/protocol/ApiKeysTest.java	75
clients/src/test/java/org/apache/kafka/common/protocol/ByteBufferAccessorTest.java	37
clients/src/test/java/org/apache/kafka/common/protocol/DataOutputStreamWritableTest.java	36
clients/src/test/java/org/apache/kafka/common/protocol/ErrorsTest.java	60
clients/src/test/java/org/apache/kafka/common/protocol/MessageUtilTest.java	91
clients/src/test/java/org/apache/kafka/common/protocol/ProtoUtilsTest.java	31
clients/src/test/java/org/apache/kafka/common/protocol/ProtocolTest.java	11
clients/src/test/java/org/apache/kafka/common/protocol/SendBuilderTest.java	116
clients/src/test/java/org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java	414
clients/src/test/java/org/apache/kafka/common/protocol/types/RawTaggedFieldWriterTest.java	72
clients/src/test/java/org/apache/kafka/common/protocol/types/StructTest.java	63
clients/src/test/java/org/apache/kafka/common/protocol/types/TypeTest.java	66
clients/src/test/java/org/apache/kafka/common/record/AbstractLegacyRecordBatchTest.java	188
clients/src/test/java/org/apache/kafka/common/record/ArbitraryMemoryRecords.java	18
clients/src/test/java/org/apache/kafka/common/record/BufferSupplierTest.java	22
clients/src/test/java/org/apache/kafka/common/record/ByteBufferLogInputStreamTest.java	84
clients/src/test/java/org/apache/kafka/common/record/CompressionRatioEstimatorTest.java	29
clients/src/test/java/org/apache/kafka/common/record/ControlRecordTypeTest.java	36
clients/src/test/java/org/apache/kafka/common/record/ControlRecordUtilsTest.java	72
clients/src/test/java/org/apache/kafka/common/record/DefaultRecordBatchTest.java	443
clients/src/test/java/org/apache/kafka/common/record/DefaultRecordTest.java	416
clients/src/test/java/org/apache/kafka/common/record/EndTransactionMarkerTest.java	113
clients/src/test/java/org/apache/kafka/common/record/FileLogInputStreamTest.java	251
clients/src/test/java/org/apache/kafka/common/record/FileRecordsTest.java	563
clients/src/test/java/org/apache/kafka/common/record/InvalidMemoryRecordsProvider.java	74
clients/src/test/java/org/apache/kafka/common/record/LegacyRecordTest.java	112
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsBuilderTest.java	533
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java	886
clients/src/test/java/org/apache/kafka/common/record/MultiRecordsSendTest.java	48
clients/src/test/java/org/apache/kafka/common/record/RemoteLogInputStreamTest.java	229
clients/src/test/java/org/apache/kafka/common/record/SimpleLegacyRecordTest.java	57
clients/src/test/java/org/apache/kafka/common/record/UnalignedFileRecordsTest.java	48
clients/src/test/java/org/apache/kafka/common/replica/ReplicaSelectorTest.java	56
clients/src/test/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequestTest.java	115
clients/src/test/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponseTest.java	102
clients/src/test/java/org/apache/kafka/common/requests/AlterPartitionRequestTest.java	58
clients/src/test/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequestTest.java	66
clients/src/test/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponseTest.java	36
clients/src/test/java/org/apache/kafka/common/requests/ApiErrorTest.java	47
clients/src/test/java/org/apache/kafka/common/requests/ApiVersionsResponseTest.java	231
clients/src/test/java/org/apache/kafka/common/requests/BrokerRegistrationRequestTest.java	124
clients/src/test/java/org/apache/kafka/common/requests/ByteBufferChannel.java	51
clients/src/test/java/org/apache/kafka/common/requests/ByteBufferChannelTest.java	60
clients/src/test/java/org/apache/kafka/common/requests/ConsumerGroupDescribeRequestTest.java	47
clients/src/test/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponseTest.java	25
clients/src/test/java/org/apache/kafka/common/requests/CreateAclsRequestTest.java	56
clients/src/test/java/org/apache/kafka/common/requests/DeleteAclsRequestTest.java	58
clients/src/test/java/org/apache/kafka/common/requests/DeleteAclsResponseTest.java	74
clients/src/test/java/org/apache/kafka/common/requests/DeleteGroupsRequestTest.java	27
clients/src/test/java/org/apache/kafka/common/requests/DeleteGroupsResponseTest.java	51
clients/src/test/java/org/apache/kafka/common/requests/DeleteTopicsRequestTest.java	95
clients/src/test/java/org/apache/kafka/common/requests/DescribeAclsRequestTest.java	41
clients/src/test/java/org/apache/kafka/common/requests/DescribeAclsResponseTest.java	99
clients/src/test/java/org/apache/kafka/common/requests/DescribeGroupsRequestTest.java	29
clients/src/test/java/org/apache/kafka/common/requests/EndTxnRequestTest.java	57
clients/src/test/java/org/apache/kafka/common/requests/EndTxnResponseTest.java	28
clients/src/test/java/org/apache/kafka/common/requests/EnvelopeRequestTest.java	45
clients/src/test/java/org/apache/kafka/common/requests/EnvelopeResponseTest.java	30
clients/src/test/java/org/apache/kafka/common/requests/FetchRequestTest.java	252
clients/src/test/java/org/apache/kafka/common/requests/FindCoordinatorRequestTest.java	11
clients/src/test/java/org/apache/kafka/common/requests/GetTelemetrySubscriptionsRequestTest.java	14
clients/src/test/java/org/apache/kafka/common/requests/GetTelemetrySubscriptionsResponseTest.java	23
clients/src/test/java/org/apache/kafka/common/requests/HeartbeatRequestTest.java	16
clients/src/test/java/org/apache/kafka/common/requests/JoinGroupRequestTest.java	42
clients/src/test/java/org/apache/kafka/common/requests/JoinGroupResponseTest.java	33
clients/src/test/java/org/apache/kafka/common/requests/LeaveGroupRequestTest.java	92
clients/src/test/java/org/apache/kafka/common/requests/LeaveGroupResponseTest.java	171
clients/src/test/java/org/apache/kafka/common/requests/ListOffsetsRequestTest.java	113
clients/src/test/java/org/apache/kafka/common/requests/MetadataRequestTest.java	76
clients/src/test/java/org/apache/kafka/common/requests/MetadataResponseTest.java	45
clients/src/test/java/org/apache/kafka/common/requests/OffsetCommitRequestTest.java	117
clients/src/test/java/org/apache/kafka/common/requests/OffsetCommitResponseTest.java	72
clients/src/test/java/org/apache/kafka/common/requests/OffsetFetchRequestTest.java	220
clients/src/test/java/org/apache/kafka/common/requests/OffsetFetchResponseTest.java	377
clients/src/test/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequestTest.java	31
clients/src/test/java/org/apache/kafka/common/requests/ProduceRequestTest.java	287
clients/src/test/java/org/apache/kafka/common/requests/ProduceResponseTest.java	73
clients/src/test/java/org/apache/kafka/common/requests/PushTelemetryRequestTest.java	87
clients/src/test/java/org/apache/kafka/common/requests/PushTelemetryResponseTest.java	23
clients/src/test/java/org/apache/kafka/common/requests/RequestContextTest.java	141
clients/src/test/java/org/apache/kafka/common/requests/RequestHeaderTest.java	81
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java	3525
clients/src/test/java/org/apache/kafka/common/requests/RequestTestUtils.java	218
clients/src/test/java/org/apache/kafka/common/requests/RequestUtilsTest.java	25
clients/src/test/java/org/apache/kafka/common/requests/SyncGroupRequestTest.java	16
clients/src/test/java/org/apache/kafka/common/requests/TxnOffsetCommitRequestTest.java	139
clients/src/test/java/org/apache/kafka/common/requests/TxnOffsetCommitResponseTest.java	41
clients/src/test/java/org/apache/kafka/common/requests/UpdateFeaturesRequestTest.java	104
clients/src/test/java/org/apache/kafka/common/requests/UpdateFeaturesResponseTest.java	52
clients/src/test/java/org/apache/kafka/common/requests/WriteTxnMarkersRequestTest.java	53
clients/src/test/java/org/apache/kafka/common/requests/WriteTxnMarkersResponseTest.java	35
clients/src/test/java/org/apache/kafka/common/resource/ResourceTypeTest.java	60
clients/src/test/java/org/apache/kafka/common/security/JaasContextTest.java	293
clients/src/test/java/org/apache/kafka/common/security/SaslExtensionsTest.java	43
clients/src/test/java/org/apache/kafka/common/security/TestSecurityConfig.java	29
clients/src/test/java/org/apache/kafka/common/security/auth/DefaultKafkaPrincipalBuilderTest.java	132
clients/src/test/java/org/apache/kafka/common/security/auth/KafkaPrincipalTest.java	13
clients/src/test/java/org/apache/kafka/common/security/authenticator/ClientAuthenticationFailureTest.java	108
clients/src/test/java/org/apache/kafka/common/security/authenticator/LoginManagerTest.java	160
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorFailureDelayTest.java	177
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorFailureNoDelayTest.java	6
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorFailurePositiveDelayTest.java	6
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java	1853
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticatorTest.java	332
clients/src/test/java/org/apache/kafka/common/security/authenticator/TestDigestLoginModule.java	47
clients/src/test/java/org/apache/kafka/common/security/authenticator/TestJaasConfig.java	121
clients/src/test/java/org/apache/kafka/common/security/kerberos/KerberosNameTest.java	98
clients/src/test/java/org/apache/kafka/common/security/kerberos/KerberosRuleTest.java	23
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerExtensionsValidatorCallbackTest.java	56
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginCallbackHandlerTest.java	225
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModuleTest.java	306
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerSaslClientCallbackHandlerTest.java	73
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenCallbackTest.java	52
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenMock.java	24
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallbackHandlerTest.java	83
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallbackTest.java	52
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerClientInitialResponseTest.java	95
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientTest.java	110
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServerTest.java	162
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshConfigTest.java	23
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshingLoginTest.java	488
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenBuilder.java	139
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenRetrieverFactoryTest.java	75
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenValidatorFactoryTest.java	44
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenValidatorTest.java	62
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/BasicOAuthBearerTokenTest.java	55
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/ClaimValidationUtilsTest.java	121
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/ConfigurationUtilsTest.java	125
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/HttpAccessTokenRetrieverTest.java	182
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/JaasOptionsUtilsTest.java	35
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/LoginAccessTokenValidatorTest.java	7
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/OAuthBearerTest.java	160
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksTest.java	203
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RetryTest.java	96
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/ValidatorAccessTokenValidatorTest.java	61
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/VerificationKeyResolverFactoryTest.java	49
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerScopeUtilsTest.java	32
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredJwsTest.java	127
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredLoginCallbackHandlerTest.java	129
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredValidatorCallbackHandlerTest.java	131
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerValidationUtilsTest.java	211
clients/src/test/java/org/apache/kafka/common/security/plain/internals/PlainSaslServerTest.java	80
clients/src/test/java/org/apache/kafka/common/security/scram/internals/ScramCredentialUtilsTest.java	66
clients/src/test/java/org/apache/kafka/common/security/scram/internals/ScramFormatterTest.java	55
clients/src/test/java/org/apache/kafka/common/security/scram/internals/ScramMessagesTest.java	250
clients/src/test/java/org/apache/kafka/common/security/scram/internals/ScramSaslServerTest.java	116
clients/src/test/java/org/apache/kafka/common/security/ssl/CommonNameLoggingSslEngineFactoryTest.java	7
clients/src/test/java/org/apache/kafka/common/security/ssl/CommonNameLoggingTrustManagerFactoryWrapperTest.java	444
clients/src/test/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactoryTest.java	276
clients/src/test/java/org/apache/kafka/common/security/ssl/SslFactoryTest.java	503
clients/src/test/java/org/apache/kafka/common/security/ssl/SslPrincipalMapperTest.java	85
clients/src/test/java/org/apache/kafka/common/security/ssl/Tls12SslFactoryTest.java	6
clients/src/test/java/org/apache/kafka/common/security/ssl/Tls13SslFactoryTest.java	9
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestKeyManagerFactory.java	79
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestPlainSaslServerProvider.java	10
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestPlainSaslServerProviderCreator.java	13
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestProvider.java	14
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestProviderCreator.java	13
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestScramSaslServerProvider.java	10
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestScramSaslServerProviderCreator.java	13
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestTrustManagerFactory.java	46
clients/src/test/java/org/apache/kafka/common/serialization/ListDeserializerTest.java	212
clients/src/test/java/org/apache/kafka/common/serialization/ListSerializerTest.java	119
clients/src/test/java/org/apache/kafka/common/serialization/SerializationTest.java	376
clients/src/test/java/org/apache/kafka/common/telemetry/ClientTelemetryStateTest.java	72
clients/src/test/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryEmitterTest.java	70
clients/src/test/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporterTest.java	614
clients/src/test/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryUtilsTest.java	141
clients/src/test/java/org/apache/kafka/common/telemetry/internals/KafkaMetricsCollectorTest.java	482
clients/src/test/java/org/apache/kafka/common/telemetry/internals/LastValueTrackerTest.java	71
clients/src/test/java/org/apache/kafka/common/telemetry/internals/SinglePointMetricTest.java	232
clients/src/test/java/org/apache/kafka/common/telemetry/internals/TelemetryMetricNamingConventionTest.java	210
clients/src/test/java/org/apache/kafka/common/telemetry/internals/TestEmitter.java	42
clients/src/test/java/org/apache/kafka/common/utils/AbstractIteratorTest.java	46
clients/src/test/java/org/apache/kafka/common/utils/AppInfoParserTest.java	68
clients/src/test/java/org/apache/kafka/common/utils/ByteBufferInputStreamTest.java	27
clients/src/test/java/org/apache/kafka/common/utils/ByteBufferOutputStreamTest.java	73
clients/src/test/java/org/apache/kafka/common/utils/ByteBufferUnmapperTest.java	16
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java	409
clients/src/test/java/org/apache/kafka/common/utils/BytesTest.java	52
clients/src/test/java/org/apache/kafka/common/utils/ChecksumsTest.java	59
clients/src/test/java/org/apache/kafka/common/utils/ChunkedBytesStreamTest.java	206
clients/src/test/java/org/apache/kafka/common/utils/CircularIteratorTest.java	39
clients/src/test/java/org/apache/kafka/common/utils/CollectionUtilsTest.java	39
clients/src/test/java/org/apache/kafka/common/utils/ConfigUtilsTest.java	53
clients/src/test/java/org/apache/kafka/common/utils/Crc32CTest.java	10
clients/src/test/java/org/apache/kafka/common/utils/ExitTest.java	65
clients/src/test/java/org/apache/kafka/common/utils/ExponentialBackoffTest.java	35
clients/src/test/java/org/apache/kafka/common/utils/FixedOrderMapTest.java	39
clients/src/test/java/org/apache/kafka/common/utils/FlattenedIteratorTest.java	74
clients/src/test/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollectionTest.java	546
clients/src/test/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiCollectionTest.java	137
clients/src/test/java/org/apache/kafka/common/utils/JavaTest.java	45
clients/src/test/java/org/apache/kafka/common/utils/LogCaptureAppender.java	140
clients/src/test/java/org/apache/kafka/common/utils/LoggingSignalHandlerTest.java	8
clients/src/test/java/org/apache/kafka/common/utils/MappedIteratorTest.java	32
clients/src/test/java/org/apache/kafka/common/utils/MockScheduler.java	71
clients/src/test/java/org/apache/kafka/common/utils/MockTime.java	81
clients/src/test/java/org/apache/kafka/common/utils/MockTimeTest.java	28
clients/src/test/java/org/apache/kafka/common/utils/PrimitiveRefTest.java	21
clients/src/test/java/org/apache/kafka/common/utils/SanitizerTest.java	55
clients/src/test/java/org/apache/kafka/common/utils/SecurityUtilsTest.java	70
clients/src/test/java/org/apache/kafka/common/utils/Serializer.java	30
clients/src/test/java/org/apache/kafka/common/utils/ShellTest.java	39
clients/src/test/java/org/apache/kafka/common/utils/SystemTimeTest.java	7
clients/src/test/java/org/apache/kafka/common/utils/ThreadUtilsTest.java	59
clients/src/test/java/org/apache/kafka/common/utils/TimeTest.java	54
clients/src/test/java/org/apache/kafka/common/utils/TimerTest.java	104
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java	935
clients/src/test/java/org/apache/kafka/common/utils/annotation/ApiKeyVersionsProvider.java	35
clients/src/test/java/org/apache/kafka/common/utils/annotation/ApiKeyVersionsProviderTest.java	77
clients/src/test/java/org/apache/kafka/common/utils/annotation/ApiKeyVersionsSource.java	16
clients/src/test/java/org/apache/kafka/server/policy/AlterConfigPolicyTest.java	28
clients/src/test/java/org/apache/kafka/test/DelayedReceive.java	16
clients/src/test/java/org/apache/kafka/test/MetricsBench.java	38
clients/src/test/java/org/apache/kafka/test/MockClusterResourceListener.java	16
clients/src/test/java/org/apache/kafka/test/MockConsumerInterceptor.java	94
clients/src/test/java/org/apache/kafka/test/MockDeserializer.java	43
clients/src/test/java/org/apache/kafka/test/MockMetricsReporter.java	30
clients/src/test/java/org/apache/kafka/test/MockPartitioner.java	27
clients/src/test/java/org/apache/kafka/test/MockProducerInterceptor.java	87
clients/src/test/java/org/apache/kafka/test/MockSelector.java	174
clients/src/test/java/org/apache/kafka/test/MockSerializer.java	29
clients/src/test/java/org/apache/kafka/test/NoRetryException.java	11
clients/src/test/java/org/apache/kafka/test/TestCondition.java	5
clients/src/test/java/org/apache/kafka/test/TestSslUtils.java	662
clients/src/test/java/org/apache/kafka/test/TestUtils.java	472
clients/src/test/java/org/apache/kafka/test/ValuelessCallable.java	4
clients/src/test/resources/log4j2.yaml	20
connect/api/src/test/java/org/apache/kafka/connect/connector/ConnectorReconfigurationTest.java	58
connect/api/src/test/java/org/apache/kafka/connect/connector/ConnectorTest.java	55
connect/api/src/test/java/org/apache/kafka/connect/data/ConnectSchemaTest.java	377
connect/api/src/test/java/org/apache/kafka/connect/data/DateTest.java	53
connect/api/src/test/java/org/apache/kafka/connect/data/DecimalTest.java	37
connect/api/src/test/java/org/apache/kafka/connect/data/FakeSchema.java	53
connect/api/src/test/java/org/apache/kafka/connect/data/FieldTest.java	18
connect/api/src/test/java/org/apache/kafka/connect/data/SchemaBuilderTest.java	296
connect/api/src/test/java/org/apache/kafka/connect/data/SchemaProjectorTest.java	381
connect/api/src/test/java/org/apache/kafka/connect/data/StructTest.java	259
connect/api/src/test/java/org/apache/kafka/connect/data/TimeTest.java	54
connect/api/src/test/java/org/apache/kafka/connect/data/TimestampTest.java	48
connect/api/src/test/java/org/apache/kafka/connect/data/ValuesTest.java	1111
connect/api/src/test/java/org/apache/kafka/connect/header/ConnectHeaderTest.java	76
connect/api/src/test/java/org/apache/kafka/connect/header/ConnectHeadersTest.java	462
connect/api/src/test/java/org/apache/kafka/connect/sink/SinkConnectorTest.java	107
connect/api/src/test/java/org/apache/kafka/connect/sink/SinkRecordTest.java	122
connect/api/src/test/java/org/apache/kafka/connect/source/SourceConnectorTest.java	112
connect/api/src/test/java/org/apache/kafka/connect/source/SourceRecordTest.java	99
connect/api/src/test/java/org/apache/kafka/connect/storage/ConverterTypeTest.java	11
connect/api/src/test/java/org/apache/kafka/connect/storage/SimpleHeaderConverterTest.java	64
connect/api/src/test/java/org/apache/kafka/connect/storage/StringConverterTest.java	72
connect/api/src/test/java/org/apache/kafka/connect/util/ConnectorUtilsTest.java	40
connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/BasicAuthSecurityRestExtensionTest.java	77
connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilterTest.java	207
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkConnectorTest.java	67
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkTaskTest.java	84
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSourceConnectorTest.java	188
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSourceTaskTest.java	178
connect/file/src/test/java/org/apache/kafka/connect/file/integration/FileStreamSinkConnectorIntegrationTest.java	129
connect/file/src/test/java/org/apache/kafka/connect/file/integration/FileStreamSourceConnectorIntegrationTest.java	141
connect/file/src/test/resources/log4j2.yaml	18
connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterConfigTest.java	17
connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterTest.java	836
connect/mirror-client/src/test/java/org/apache/kafka/connect/mirror/MirrorClientTest.java	174
connect/mirror-client/src/test/java/org/apache/kafka/connect/mirror/ReplicationPolicyTest.java	58
connect/mirror-client/src/test/java/org/apache/kafka/connect/mirror/SourceAndTargetTest.java	28
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/CheckpointStoreTest.java	65
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/CheckpointTest.java	23
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/HeartbeatTest.java	20
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointConfigTest.java	98
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnectorTest.java	265
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointTaskTest.java	282
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorConfigTest.java	174
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorHeartBeatConnectorTest.java	131
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorHeartbeatTaskTest.java	21
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorMakerConfigTest.java	327
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConfigTest.java	140
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java	621
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceMetricsTest.java	62
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceTaskTest.java	286
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorUtilsTest.java	107
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncStoreTest.java	249
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncTest.java	21
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncWriterTest.java	73
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/TestUtils.java	49
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/clients/admin/FakeForwardingAdminWithLocalMetadata.java	61
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/clients/admin/FakeLocalMetadataStore.java	57
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/DedicatedMirrorIntegrationTest.java	354
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/IdentityReplicationIntegrationTest.java	20
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java	1139
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationExactlyOnceTest.java	57
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationSSLTest.java	33
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationTransactionsTest.java	43
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java	264
connect/mirror/src/test/resources/log4j2.yaml	22
connect/runtime/src/test/java/org/apache/kafka/connect/cli/ConnectStandaloneTest.java	90
connect/runtime/src/test/java/org/apache/kafka/connect/connector/policy/BaseConnectorClientConfigOverridePolicyTest.java	33
connect/runtime/src/test/java/org/apache/kafka/connect/connector/policy/NoneConnectorClientConfigOverridePolicyTest.java	25
connect/runtime/src/test/java/org/apache/kafka/connect/connector/policy/PrincipalConnectorClientConfigOverridePolicyTest.java	26
connect/runtime/src/test/java/org/apache/kafka/connect/converters/BooleanConverterTest.java	81
connect/runtime/src/test/java/org/apache/kafka/connect/converters/ByteArrayConverterTest.java	86
connect/runtime/src/test/java/org/apache/kafka/connect/converters/DoubleConverterTest.java	21
connect/runtime/src/test/java/org/apache/kafka/connect/converters/FloatConverterTest.java	21
connect/runtime/src/test/java/org/apache/kafka/connect/converters/IntegerConverterTest.java	21
connect/runtime/src/test/java/org/apache/kafka/connect/converters/LongConverterTest.java	21
connect/runtime/src/test/java/org/apache/kafka/connect/converters/NumberConverterTest.java	76
connect/runtime/src/test/java/org/apache/kafka/connect/converters/ShortConverterTest.java	21
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java	693
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectWorkerIntegrationTest.java	1028
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorClientPolicyIntegrationTest.java	114
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorHandle.java	153
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorRestartApiIntegrationTest.java	306
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorTopicsIntegrationTest.java	214
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java	513
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ErrantRecordSinkConnector.java	54
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ErrorHandlingIntegrationTest.java	228
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ExactlyOnceSourceIntegrationTest.java	922
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ExampleConnectIntegrationTest.java	129
connect/runtime/src/test/java/org/apache/kafka/connect/integration/InternalTopicsIntegrationTest.java	236
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSinkConnector.java	41
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSinkIntegrationTest.java	96
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSourceConnector.java	44
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSourceIntegrationTest.java	81
connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java	803
connect/runtime/src/test/java/org/apache/kafka/connect/integration/RebalanceSourceConnectorsIntegrationTest.java	232
connect/runtime/src/test/java/org/apache/kafka/connect/integration/RestExtensionIntegrationTest.java	150
connect/runtime/src/test/java/org/apache/kafka/connect/integration/RestForwardingIntegrationTest.java	207
connect/runtime/src/test/java/org/apache/kafka/connect/integration/RuntimeHandles.java	18
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SessionedProtocolIntegrationTest.java	106
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SinkConnectorsIntegrationTest.java	249
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SourceConnectorsIntegrationTest.java	158
connect/runtime/src/test/java/org/apache/kafka/connect/integration/StandaloneWorkerIntegrationTest.java	297
connect/runtime/src/test/java/org/apache/kafka/connect/integration/StartAndStopCounter.java	60
connect/runtime/src/test/java/org/apache/kafka/connect/integration/StartAndStopCounterTest.java	85
connect/runtime/src/test/java/org/apache/kafka/connect/integration/StartAndStopLatch.java	48
connect/runtime/src/test/java/org/apache/kafka/connect/integration/StartAndStopLatchTest.java	105
connect/runtime/src/test/java/org/apache/kafka/connect/integration/StartsAndStops.java	3
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TaskHandle.java	194
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TestableSinkConnector.java	120
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TestableSourceConnector.java	237
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.java	198
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java	1102
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTaskTest.java	765
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectMetricsTest.java	349
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectorConfigTest.java	427
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java	452
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTaskTest.java	998
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/InternalSinkRecordTest.java	44
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/LoggersTest.java	143
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/MockConnectMetrics.java	92
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/MockLoggersTest.java	195
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/RestartPlanTest.java	65
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/RestartRequestTest.java	80
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SampleConverterWithHeaders.java	54
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SampleHeaderConverter.java	34
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SamplePredicate.java	34
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SampleSinkConnector.java	38
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SampleSourceConnector.java	56
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SampleTransformation.java	34
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SourceConnectorConfigTest.java	122
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitterTest.java	125
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/StateTrackerTest.java	72
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SubmittedRecordsTest.java	281
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TransformationConfigTest.java	160
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TransformationStageTest.java	54
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConfigTest.java	77
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConfigTransformerTest.java	110
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConnectorTest.java	535
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerMetricsGroupTest.java	134
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java	1530
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java	565
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java	796
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java	258
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java	2600
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTestUtils.java	167
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTransactionContextTest.java	78
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocolCompatibilityTest.java	186
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedConfigTest.java	385
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java	3250
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java	1199
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/SampleConnectorClientConfigOverridePolicy.java	12
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorIncrementalTest.java	455
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.java	499
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMemberTest.java	92
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/ErrorReporterTest.java	263
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTest.java	386
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporterTest.java	85
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/health/ConnectClusterStateImplTest.java	83
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoaderTest.java	89
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginDescTest.java	268
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginScannerTest.java	121
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginUtilsTest.java	603
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginsTest.java	656
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/SamplingTestPlugin.java	71
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/SynchronizationTest.java	346
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/TestPlugins.java	290
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/ConnectRestServerTest.java	379
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignatureTest.java	115
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestClientTest.java	284
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestServerConfigTest.java	119
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorOffsetsTest.java	27
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorTypeTest.java	23
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequestTest.java	28
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/PluginInfoTest.java	15
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResourceTest.java	429
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResourceTest.java	783
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/InternalConnectResourceTest.java	185
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResourceTest.java	128
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/RootResourceTest.java	126
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/util/SSLUtilsTest.java	151
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneConfigTest.java	60
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java	1034
connect/runtime/src/test/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStoreTest.java	372
connect/runtime/src/test/java/org/apache/kafka/connect/storage/FileOffsetBackingStoreTest.java	153
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaConfigBackingStoreTest.java	1316
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java	441
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreFormatTest.java	220
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreTest.java	329
connect/runtime/src/test/java/org/apache/kafka/connect/storage/MemoryConfigBackingStoreTest.java	140
connect/runtime/src/test/java/org/apache/kafka/connect/storage/MemoryStatusBackingStoreTest.java	41
connect/runtime/src/test/java/org/apache/kafka/connect/storage/OffsetStorageWriterTest.java	164
connect/runtime/src/test/java/org/apache/kafka/connect/storage/OffsetUtilsTest.java	112
connect/runtime/src/test/java/org/apache/kafka/connect/test/util/ConcurrencyUtils.java	17
connect/runtime/src/test/java/org/apache/kafka/connect/test/util/MockitoUtils.java	18
connect/runtime/src/test/java/org/apache/kafka/connect/util/ConnectUtilsTest.java	153
connect/runtime/src/test/java/org/apache/kafka/connect/util/ConvertingFutureCallbackTest.java	199
connect/runtime/src/test/java/org/apache/kafka/connect/util/KafkaBasedLogTest.java	441
connect/runtime/src/test/java/org/apache/kafka/connect/util/LoggingContextTest.java	156
connect/runtime/src/test/java/org/apache/kafka/connect/util/RetryUtilTest.java	144
connect/runtime/src/test/java/org/apache/kafka/connect/util/SharedTopicAdminTest.java	73
connect/runtime/src/test/java/org/apache/kafka/connect/util/SinkUtilsTest.java	141
connect/runtime/src/test/java/org/apache/kafka/connect/util/TableTest.java	24
connect/runtime/src/test/java/org/apache/kafka/connect/util/TestFuture.java	70
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicAdminTest.java	831
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicCreationTest.java	508
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/ConnectAssertions.java	400
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java	605
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectBuilder.java	45
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java	141
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectStandalone.java	141
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java	472
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/UngracefulShutdownException.java	13
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/WorkerHandle.java	61
connect/runtime/src/test/resources/log4j2.yaml	26
connect/runtime/src/test/resources/test-plugins/aliased-static-field/test/plugins/AliasedStaticField.java	42
connect/runtime/src/test/resources/test-plugins/always-throw-exception/test/plugins/AlwaysThrowException.java	24
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/CoLocatedPlugin.java	18
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/DefaultConstructorPrivateConnector.java	32
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/DefaultConstructorThrowsConnector.java	33
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/DefaultConstructorThrowsConverter.java	42
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/InnocuousSinkConnector.java	49
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/MissingSuperclassConverter.java	18
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/NoDefaultConstructorConnector.java	32
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/NoDefaultConstructorConverter.java	41
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/NoDefaultConstructorOverridePolicy.java	21
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/NonExistentInterface.java	3
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/OuterClass.java	32
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/StaticInitializerThrowsConnector.java	36
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/StaticInitializerThrowsRestExtension.java	30
connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/VersionMethodThrowsConnector.java	30
connect/runtime/src/test/resources/test-plugins/classpath-converter/org/apache/kafka/connect/converters/ByteArrayConverter.java	64
connect/runtime/src/test/resources/test-plugins/multiple-plugins-in-jar/test/plugins/ThingOne.java	19
connect/runtime/src/test/resources/test-plugins/multiple-plugins-in-jar/test/plugins/ThingTwo.java	20
connect/runtime/src/test/resources/test-plugins/non-migrated/test/plugins/NonMigratedConverter.java	18
connect/runtime/src/test/resources/test-plugins/non-migrated/test/plugins/NonMigratedHeaderConverter.java	27
connect/runtime/src/test/resources/test-plugins/non-migrated/test/plugins/NonMigratedMultiPlugin.java	57
connect/runtime/src/test/resources/test-plugins/non-migrated/test/plugins/NonMigratedPredicate.java	21
connect/runtime/src/test/resources/test-plugins/non-migrated/test/plugins/NonMigratedSinkConnector.java	30
connect/runtime/src/test/resources/test-plugins/non-migrated/test/plugins/NonMigratedSourceConnector.java	30
connect/runtime/src/test/resources/test-plugins/non-migrated/test/plugins/NonMigratedTransformation.java	21
connect/runtime/src/test/resources/test-plugins/read-version-from-resource-v1/test/plugins/ReadVersionFromResource.java	59
connect/runtime/src/test/resources/test-plugins/read-version-from-resource-v2/test/plugins/ReadVersionFromResource.java	59
connect/runtime/src/test/resources/test-plugins/sampling-config-provider/test/plugins/SamplingConfigProvider.java	79
connect/runtime/src/test/resources/test-plugins/sampling-configurable/test/plugins/SamplingConfigurable.java	60
connect/runtime/src/test/resources/test-plugins/sampling-connector/test/plugins/SamplingConnector.java	73
connect/runtime/src/test/resources/test-plugins/sampling-converter/test/plugins/SamplingConverter.java	58
connect/runtime/src/test/resources/test-plugins/sampling-header-converter/test/plugins/SamplingHeaderConverter.java	69
connect/runtime/src/test/resources/test-plugins/service-loader/test/plugins/ServiceLoadedClass.java	20
connect/runtime/src/test/resources/test-plugins/service-loader/test/plugins/ServiceLoadedSubclass.java	19
connect/runtime/src/test/resources/test-plugins/service-loader/test/plugins/ServiceLoaderPlugin.java	54
connect/runtime/src/test/resources/test-plugins/subclass-of-classpath/test/plugins/SubclassOfClasspathConverter.java	4
connect/runtime/src/test/resources/test-plugins/subclass-of-classpath/test/plugins/SubclassOfClasspathOverridePolicy.java	5
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/CastTest.java	494
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/DropHeadersTest.java	89
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ExtractFieldTest.java	183
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/FlattenTest.java	304
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/HeaderFromTest.java	334
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/HoistFieldTest.java	54
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertFieldTest.java	182
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertHeaderTest.java	91
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/MaskFieldTest.java	234
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/RegexRouterTest.java	48
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ReplaceFieldTest.java	142
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/SetSchemaMetadataTest.java	164
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/TimestampConverterTest.java	571
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/TimestampRouterTest.java	35
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ValueToKeyTest.java	102
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/FieldPathNotationTest.java	98
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/FieldSyntaxVersionTest.java	48
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/SingleFieldPathTest.java	84
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKeyTest.java	86
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatchesTest.java	63
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidatorTest.java	20
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorExecutorImplTest.java	256
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRecordTest.java	37
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorResultTest.java	23
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntimeMetricsImplTest.java	177
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntimeTest.java	3145
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/DirectEventProcessor.java	22
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/EventAccumulatorTest.java	184
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/HdrHistogramTest.java	183
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/InMemoryPartitionWriter.java	140
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/KafkaMetricHistogramTest.java	32
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/ManualEventProcessor.java	30
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorExecutor.java	94
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorLoader.java	32
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorShard.java	107
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorShardBuilder.java	62
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorShardBuilderSupplier.java	7
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorTimer.java	126
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockPartitionWriter.java	55
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MultiThreadedEventProcessorTest.java	365
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinatorTest.java	111
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/StringSerializer.java	12
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/TestUtil.java	165
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/ThrowingSerializer.java	25
core/src/test/java/kafka/security/JaasModule.java	86
core/src/test/java/kafka/security/JaasTestUtils.java	286
core/src/test/java/kafka/security/minikdc/MiniKdc.java	366
core/src/test/java/kafka/security/minikdc/MiniKdcTest.java	29
core/src/test/java/kafka/server/MetadataVersionConfigValidatorTest.java	71
core/src/test/java/kafka/server/ReconfigurableQuorumIntegrationTest.java	142
core/src/test/java/kafka/server/handlers/DescribeTopicPartitionsRequestHandlerTest.java	474
core/src/test/java/kafka/server/integration/EligibleLeaderReplicasIntegrationTest.java	376
core/src/test/java/kafka/server/logger/RuntimeLoggerManagerTest.java	71
core/src/test/java/kafka/server/share/DelayedShareFetchTest.java	1484
core/src/test/java/kafka/server/share/ShareCoordinatorMetadataCacheHelperImplTest.java	363
core/src/test/java/kafka/server/share/ShareFetchUtilsTest.java	485
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java	2400
core/src/test/java/kafka/server/share/SharePartitionTest.java	5574
core/src/test/resources/log4j2.yaml	20
core/src/test/scala/integration/kafka/admin/RemoteTopicCrudTest.scala	518
core/src/test/scala/integration/kafka/api/AbstractAuthorizerIntegrationTest.scala	96
core/src/test/scala/integration/kafka/api/AbstractConsumerTest.scala	383
core/src/test/scala/integration/kafka/api/AbstractSaslTest.scala	3
core/src/test/scala/integration/kafka/api/AdminClientWithPoliciesIntegrationTest.scala	180
core/src/test/scala/integration/kafka/api/BaseAdminIntegrationTest.scala	203
core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala	112
core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala	409
core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala	318
core/src/test/scala/integration/kafka/api/ClientIdQuotaTest.scala	54
core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala	434
core/src/test/scala/integration/kafka/api/ConsumerWithLegacyMessageFormatIntegrationTest.scala	107
core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala	391
core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala	115
core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationWithOwnerTest.scala	97
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala	429
core/src/test/scala/integration/kafka/api/EndToEndClusterIdTest.scala	150
core/src/test/scala/integration/kafka/api/FixedPortTestUtils.scala	25
core/src/test/scala/integration/kafka/api/GroupAuthorizerIntegrationTest.scala	182
core/src/test/scala/integration/kafka/api/GroupCoordinatorIntegrationTest.scala	260
core/src/test/scala/integration/kafka/api/GroupEndToEndAuthorizationTest.scala	28
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala	191
core/src/test/scala/integration/kafka/api/MetricsTest.scala	261
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala	3213
core/src/test/scala/integration/kafka/api/PlaintextConsumerAssignTest.scala	156
core/src/test/scala/integration/kafka/api/PlaintextConsumerAssignorsTest.scala	252
core/src/test/scala/integration/kafka/api/PlaintextConsumerCommitTest.scala	248
core/src/test/scala/integration/kafka/api/PlaintextConsumerPollTest.scala	217
core/src/test/scala/integration/kafka/api/PlaintextConsumerSubscriptionTest.scala	299
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala	697
core/src/test/scala/integration/kafka/api/PlaintextEndToEndAuthorizationTest.scala	67
core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala	212
core/src/test/scala/integration/kafka/api/ProducerSendWhileDeletionTest.scala	92
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala	184
core/src/test/scala/integration/kafka/api/SaslEndToEndAuthorizationTest.scala	51
core/src/test/scala/integration/kafka/api/SaslGssapiSslEndToEndAuthorizationTest.scala	20
core/src/test/scala/integration/kafka/api/SaslMultiMechanismConsumerTest.scala	68
core/src/test/scala/integration/kafka/api/SaslOAuthBearerSslEndToEndAuthorizationTest.scala	9
core/src/test/scala/integration/kafka/api/SaslPlainPlaintextConsumerTest.scala	29
core/src/test/scala/integration/kafka/api/SaslPlaintextConsumerTest.scala	18
core/src/test/scala/integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala	47
core/src/test/scala/integration/kafka/api/SaslSetup.scala	126
core/src/test/scala/integration/kafka/api/SaslSslAdminIntegrationTest.scala	589
core/src/test/scala/integration/kafka/api/SaslSslConsumerTest.scala	20
core/src/test/scala/integration/kafka/api/SslAdminIntegrationTest.scala	285
core/src/test/scala/integration/kafka/api/SslConsumerTest.scala	9
core/src/test/scala/integration/kafka/api/SslEndToEndAuthorizationTest.scala	56
core/src/test/scala/integration/kafka/api/SslProducerSendTest.scala	7
core/src/test/scala/integration/kafka/api/TransactionsBounceTest.scala	151
core/src/test/scala/integration/kafka/api/TransactionsTest.scala	768
core/src/test/scala/integration/kafka/api/UserClientIdQuotaTest.scala	60
core/src/test/scala/integration/kafka/api/UserQuotaTest.scala	58
core/src/test/scala/integration/kafka/coordinator/transaction/ProducerIntegrationTest.scala	181
core/src/test/scala/integration/kafka/network/DynamicConnectionQuotaTest.scala	315
core/src/test/scala/integration/kafka/network/DynamicNumNetworkThreadsTest.scala	78
core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala	216
core/src/test/scala/integration/kafka/server/DelayedRemoteFetchTest.scala	181
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala	1291
core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala	217
core/src/test/scala/integration/kafka/server/GssapiAuthenticationTest.scala	235
core/src/test/scala/integration/kafka/server/IntegrationTestUtils.scala	74
core/src/test/scala/integration/kafka/server/KRaftClusterTest.scala	1582
core/src/test/scala/integration/kafka/server/MultipleListenersWithAdditionalJaasContextTest.scala	22
core/src/test/scala/integration/kafka/server/MultipleListenersWithDefaultJaasContextTest.scala	9
core/src/test/scala/integration/kafka/server/MultipleListenersWithSameSecurityProtocolBaseTest.scala	155
core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala	348
core/src/test/scala/integration/kafka/server/RaftClusterSnapshotTest.scala	74
core/src/test/scala/kafka/raft/DefaultExternalKRaftMetricsTest.scala	32
core/src/test/scala/kafka/raft/KafkaMetadataLogTest.scala	909
core/src/test/scala/kafka/server/KafkaRequestHandlerTest.scala	526
core/src/test/scala/kafka/server/LocalLeaderEndPointTest.scala	237
core/src/test/scala/kafka/server/NodeToControllerRequestThreadTest.scala	341
core/src/test/scala/kafka/server/RemoteLeaderEndPointTest.scala	116
core/src/test/scala/kafka/server/metadata/ClientQuotaMetadataManagerTest.scala	54
core/src/test/scala/kafka/tools/LogCompactionTester.scala	276
core/src/test/scala/kafka/utils/LoggingTest.scala	54
core/src/test/scala/kafka/utils/TestInfoUtils.scala	32
core/src/test/scala/unit/kafka/KafkaConfigTest.scala	247
core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala	170
core/src/test/scala/unit/kafka/cluster/AbstractPartitionTest.scala	138
core/src/test/scala/unit/kafka/cluster/AssignmentStateTest.scala	94
core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala	354
core/src/test/scala/unit/kafka/cluster/PartitionTest.scala	3327
core/src/test/scala/unit/kafka/cluster/ReplicaTest.scala	288
core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala	241
core/src/test/scala/unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala	519
core/src/test/scala/unit/kafka/coordinator/group/CoordinatorPartitionWriterTest.scala	257
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorConcurrencyTest.scala	520
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala	1523
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionLogTest.scala	182
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala	504
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandlerTest.scala	179
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMetadataTest.scala	656
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionStateManagerTest.scala	1056
core/src/test/scala/unit/kafka/docker/KafkaDockerWrapperTest.scala	379
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala	253
core/src/test/scala/unit/kafka/integration/MinIsrConfigTest.scala	18
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala	284
core/src/test/scala/unit/kafka/log/AbstractLogCleanerIntegrationTest.scala	142
core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala	162
core/src/test/scala/unit/kafka/log/LogCleanerLagIntegrationTest.scala	81
core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala	629
core/src/test/scala/unit/kafka/log/LogCleanerParameterizedIntegrationTest.scala	265
core/src/test/scala/unit/kafka/log/LogCleanerTest.scala	1698
core/src/test/scala/unit/kafka/log/LogConcurrencyTest.scala	146
core/src/test/scala/unit/kafka/log/LogConfigTest.scala	364
core/src/test/scala/unit/kafka/log/LogLoaderTest.scala	1244
core/src/test/scala/unit/kafka/log/LogManagerTest.scala	906
core/src/test/scala/unit/kafka/log/LogTestUtils.scala	238
core/src/test/scala/unit/kafka/log/UnifiedLogTest.scala	3547
core/src/test/scala/unit/kafka/metrics/KafkaMetricsGroupTest.scala	43
core/src/test/scala/unit/kafka/metrics/MetricsTest.scala	187
core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala	713
core/src/test/scala/unit/kafka/network/ProcessorTest.scala	69
core/src/test/scala/unit/kafka/network/RequestChannelTest.scala	252
core/src/test/scala/unit/kafka/network/RequestConvertToJsonTest.scala	99
core/src/test/scala/unit/kafka/network/SocketServerTest.scala	1815
core/src/test/scala/unit/kafka/raft/RaftManagerTest.scala	194
core/src/test/scala/unit/kafka/security/authorizer/AuthorizerTest.scala	543
core/src/test/scala/unit/kafka/security/authorizer/BaseAuthorizerTest.scala	296
core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala	98
core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala	154
core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala	256
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala	877
core/src/test/scala/unit/kafka/server/AbstractMetadataRequestTest.scala	38
core/src/test/scala/unit/kafka/server/AddPartitionsToTxnManagerTest.scala	357
core/src/test/scala/unit/kafka/server/AddPartitionsToTxnRequestServerTest.scala	158
core/src/test/scala/unit/kafka/server/AllocateProducerIdsRequestTest.scala	61
core/src/test/scala/unit/kafka/server/AlterPartitionManagerTest.scala	403
core/src/test/scala/unit/kafka/server/AlterReplicaLogDirsRequestTest.scala	140
core/src/test/scala/unit/kafka/server/AlterUserScramCredentialsRequestNotAuthorizedTest.scala	61
core/src/test/scala/unit/kafka/server/AlterUserScramCredentialsRequestTest.scala	399
core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala	68
core/src/test/scala/unit/kafka/server/ApiVersionsResponseIntegrationTest.scala	51
core/src/test/scala/unit/kafka/server/AuthHelperTest.scala	218
core/src/test/scala/unit/kafka/server/AutoTopicCreationManagerTest.scala	310
core/src/test/scala/unit/kafka/server/BaseClientQuotaManagerTest.scala	57
core/src/test/scala/unit/kafka/server/BaseFetchRequestTest.scala	83
core/src/test/scala/unit/kafka/server/BaseRequestTest.scala	101
core/src/test/scala/unit/kafka/server/BrokerLifecycleManagerTest.scala	243
core/src/test/scala/unit/kafka/server/BrokerMetricNamesTest.scala	26
core/src/test/scala/unit/kafka/server/BrokerRegistrationRequestTest.scala	127
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala	397
core/src/test/scala/unit/kafka/server/ClientQuotasRequestTest.scala	447
core/src/test/scala/unit/kafka/server/ClientRequestQuotaManagerTest.scala	55
core/src/test/scala/unit/kafka/server/ConfigAdminManagerTest.scala	375
core/src/test/scala/unit/kafka/server/ConsumerGroupDescribeRequestTest.scala	255
core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala	520
core/src/test/scala/unit/kafka/server/ConsumerProtocolMigrationTest.scala	1057
core/src/test/scala/unit/kafka/server/ControllerApisTest.scala	1181
core/src/test/scala/unit/kafka/server/ControllerConfigurationValidatorTest.scala	175
core/src/test/scala/unit/kafka/server/ControllerMutationQuotaManagerTest.scala	164
core/src/test/scala/unit/kafka/server/ControllerMutationQuotaTest.scala	329
core/src/test/scala/unit/kafka/server/ControllerRegistrationManagerTest.scala	234
core/src/test/scala/unit/kafka/server/CreateTopicsRequestTest.scala	128
core/src/test/scala/unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala	126
core/src/test/scala/unit/kafka/server/DefaultApiVersionManagerTest.scala	109
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsOnPlainTextTest.scala	46
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsTest.scala	118
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsWithDisableTokenFeatureTest.scala	55
core/src/test/scala/unit/kafka/server/DeleteGroupsRequestTest.scala	76
core/src/test/scala/unit/kafka/server/DeleteRecordsRequestTest.scala	103
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestTest.scala	113
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestWithDeletionDisabledTest.scala	52
core/src/test/scala/unit/kafka/server/DescribeClusterRequestTest.scala	69
core/src/test/scala/unit/kafka/server/DescribeGroupsRequestTest.scala	78
core/src/test/scala/unit/kafka/server/DescribeLogDirsRequestTest.scala	55
core/src/test/scala/unit/kafka/server/DescribeQuorumRequestTest.scala	70
core/src/test/scala/unit/kafka/server/DescribeUserScramCredentialsRequestNotAuthorizedTest.scala	31
core/src/test/scala/unit/kafka/server/DescribeUserScramCredentialsRequestTest.scala	97
core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala	838
core/src/test/scala/unit/kafka/server/DynamicConfigChangeTest.scala	522
core/src/test/scala/unit/kafka/server/EdgeCaseRequestTest.scala	160
core/src/test/scala/unit/kafka/server/FetchRequestMaxBytesTest.scala	97
core/src/test/scala/unit/kafka/server/FetchRequestTest.scala	499
core/src/test/scala/unit/kafka/server/FetchSessionTest.scala	1691
core/src/test/scala/unit/kafka/server/FetcherThreadTestUtils.scala	16
core/src/test/scala/unit/kafka/server/ForwardingManagerTest.scala	240
core/src/test/scala/unit/kafka/server/GroupCoordinatorBaseRequestTest.scala	828
core/src/test/scala/unit/kafka/server/HeartbeatRequestTest.scala	136
core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala	154
core/src/test/scala/unit/kafka/server/IsrExpirationTest.scala	178
core/src/test/scala/unit/kafka/server/JoinGroupRequestTest.scala	317
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala	1515
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala	82
core/src/test/scala/unit/kafka/server/KafkaMetricsReporterTest.scala	64
core/src/test/scala/unit/kafka/server/KafkaRaftServerTest.scala	251
core/src/test/scala/unit/kafka/server/LeaveGroupRequestTest.scala	160
core/src/test/scala/unit/kafka/server/ListGroupsRequestTest.scala	182
core/src/test/scala/unit/kafka/server/ListOffsetsRequestTest.scala	205
core/src/test/scala/unit/kafka/server/ListOffsetsRequestWithRemoteStoreTest.scala	23
core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala	160
core/src/test/scala/unit/kafka/server/LogOffsetTest.scala	196
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala	182
core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala	858
core/src/test/scala/unit/kafka/server/MetadataRequestTest.scala	256
core/src/test/scala/unit/kafka/server/MockFetcherThread.scala	142
core/src/test/scala/unit/kafka/server/MockLeaderEndPoint.scala	225
core/src/test/scala/unit/kafka/server/MockNodeToControllerChannelManager.scala	71
core/src/test/scala/unit/kafka/server/MockTierStateMachine.scala	20
core/src/test/scala/unit/kafka/server/OffsetCommitRequestTest.scala	119
core/src/test/scala/unit/kafka/server/OffsetDeleteRequestTest.scala	113
core/src/test/scala/unit/kafka/server/OffsetFetchRequestTest.scala	395
core/src/test/scala/unit/kafka/server/OffsetsForLeaderEpochRequestTest.scala	89
core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala	248
core/src/test/scala/unit/kafka/server/RegistrationTestContext.scala	52
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala	948
core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala	49
core/src/test/scala/unit/kafka/server/ReplicaFetcherThreadTest.scala	645
core/src/test/scala/unit/kafka/server/ReplicaManagerConcurrencyTest.scala	429
core/src/test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala	274
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala	5186
core/src/test/scala/unit/kafka/server/ReplicationQuotaManagerTest.scala	68
core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala	209
core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala	690
core/src/test/scala/unit/kafka/server/SaslApiVersionsRequestTest.scala	78
core/src/test/scala/unit/kafka/server/ServerMetricsTest.scala	25
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala	178
core/src/test/scala/unit/kafka/server/ServerTest.scala	28
core/src/test/scala/unit/kafka/server/ShareFetchAcknowledgeRequestTest.scala	1954
core/src/test/scala/unit/kafka/server/ShareGroupDescribeRequestTest.scala	105
core/src/test/scala/unit/kafka/server/ShareGroupHeartbeatRequestTest.scala	707
core/src/test/scala/unit/kafka/server/SyncGroupRequestTest.scala	201
core/src/test/scala/unit/kafka/server/ThrottledChannelExpirationTest.scala	59
core/src/test/scala/unit/kafka/server/TierStateMachineTest.scala	129
core/src/test/scala/unit/kafka/server/TxnOffsetCommitRequestTest.scala	182
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala	406
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochIntegrationTest.scala	229
core/src/test/scala/unit/kafka/server/epoch/OffsetsForLeaderEpochTest.scala	137
core/src/test/scala/unit/kafka/server/epoch/util/MockBlockingSender.scala	107
core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataPublisherTest.scala	188
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala	971
core/src/test/scala/unit/kafka/tools/StorageToolTest.scala	644
core/src/test/scala/unit/kafka/utils/CoreUtilsTest.scala	52
core/src/test/scala/unit/kafka/utils/SchedulerTest.scala	187
core/src/test/scala/unit/kafka/utils/TestUtils.scala	1218
docker/docker_build_test.py	45
docker/docker_official_image_build_test.py	48
docker/test/__init__.py	1
docker/test/constants.py	23
docker/test/docker_sanity_test.py	190
generator/src/test/java/org/apache/kafka/message/CodeBufferTest.java	48
generator/src/test/java/org/apache/kafka/message/EntityTypeTest.java	59
generator/src/test/java/org/apache/kafka/message/IsNullConditionalTest.java	96
generator/src/test/java/org/apache/kafka/message/MessageDataGeneratorTest.java	286
generator/src/test/java/org/apache/kafka/message/MessageGeneratorTest.java	113
generator/src/test/java/org/apache/kafka/message/StructRegistryTest.java	142
generator/src/test/java/org/apache/kafka/message/StructSpecTest.java	46
generator/src/test/java/org/apache/kafka/message/VersionConditionalTest.java	209
generator/src/test/java/org/apache/kafka/message/VersionsTest.java	81
generator/src/test/java/org/apache/kafka/message/checker/CheckerTestUtils.java	127
generator/src/test/java/org/apache/kafka/message/checker/CheckerUtilsTest.java	60
generator/src/test/java/org/apache/kafka/message/checker/EvolutionVerifierTest.java	170
generator/src/test/java/org/apache/kafka/message/checker/FieldDomainTest.java	35
generator/src/test/java/org/apache/kafka/message/checker/MetadataSchemaCheckerToolTest.java	54
generator/src/test/java/org/apache/kafka/message/checker/UnifierTest.java	180
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/Assertions.java	318
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/AssignmentTestUtil.java	78
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupConfigManagerTest.java	60
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupConfigTest.java	199
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfigTest.java	266
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpersTest.java	775
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordSerdeTest.java	191
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorServiceTest.java	4553
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorShardTest.java	2105
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTestContext.java	1534
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/MetadataImageBuilder.java	44
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/MockPartitionAssignor.java	33
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/NoOpPartitionAssignor.java	21
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetAndMetadataTest.java	143
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetExpirationConditionImplTest.java	37
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java	2685
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/ShareGroupAutoOffsetResetStrategyTest.java	79
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/GroupSpecImplTest.java	80
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilderTest.java	554
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeAssignorTest.java	753
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeSetTest.java	98
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/SimpleAssignorTest.java	685
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/UniformHeterogeneousAssignmentBuilderTest.java	622
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/classic/ClassicGroupMemberTest.java	257
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/classic/ClassicGroupTest.java	1398
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShardTest.java	29
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsTest.java	291
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/metrics/MetricsTestUtils.java	39
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/AssignmentTest.java	53
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/SubscribedTopicMetadataTest.java	70
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilderTest.java	760
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TopicIdsTest.java	147
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TopicMetadataTest.java	42
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/UnionSetTest.java	101
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupBuilder.java	86
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupMemberTest.java	331
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupTest.java	1779
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilderTest.java	495
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ResolvedRegularExpressionTest.java	45
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupAssignmentBuilderTest.java	68
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupBuilder.java	75
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfigTest.java	94
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupMemberTest.java	148
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupTest.java	551
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/CurrentAssignmentBuilderTest.java	720
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/MockTaskAssignor.java	45
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsCoordinatorRecordHelpersTest.java	774
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupBuilder.java	77
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMemberTest.java	376
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupTest.java	881
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsTopologyTest.java	177
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilderTest.java	669
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TaskAssignmentTestUtil.java	37
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TasksTupleTest.java	138
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TopicMetadataTest.java	59
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TopologyMetadataTest.java	89
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImplTest.java	34
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/MockAssignorTest.java	211
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessStateTest.java	81
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignorTest.java	972
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ChangelogTopicsTest.java	130
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredInternalTopicTest.java	47
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredSubtopologyTest.java	76
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredTopologyTest.java	100
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/CopartitionedTopicsEnforcerTest.java	191
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/EndpointToPartitionsManagerTest.java	124
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/InternalTopicManagerTest.java	143
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/RepartitionTopicsTest.java	158
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/TopicConfigurationExceptionTest.java	24
group-coordinator/src/test/resources/log4j2.yaml	18
metadata/src/test/java/org/apache/kafka/controller/AclControlManagerTest.java	284
metadata/src/test/java/org/apache/kafka/controller/ActivationRecordsGeneratorTest.java	90
metadata/src/test/java/org/apache/kafka/controller/BrokerHeartbeatManagerTest.java	215
metadata/src/test/java/org/apache/kafka/controller/BrokerHeartbeatTrackerTest.java	92
metadata/src/test/java/org/apache/kafka/controller/BrokerToElrsTest.java	47
metadata/src/test/java/org/apache/kafka/controller/BrokersToIsrsTest.java	79
metadata/src/test/java/org/apache/kafka/controller/ClientQuotaControlManagerTest.java	389
metadata/src/test/java/org/apache/kafka/controller/ClusterControlManagerTest.java	1022
metadata/src/test/java/org/apache/kafka/controller/ConfigurationControlManagerTest.java	476
metadata/src/test/java/org/apache/kafka/controller/ControllerRequestContextUtil.java	43
metadata/src/test/java/org/apache/kafka/controller/EventPerformanceMonitorTest.java	88
metadata/src/test/java/org/apache/kafka/controller/FeatureControlManagerTest.java	425
metadata/src/test/java/org/apache/kafka/controller/MockAclMutator.java	62
metadata/src/test/java/org/apache/kafka/controller/OffsetControlManagerTest.java	221
metadata/src/test/java/org/apache/kafka/controller/PartitionChangeBuilderTest.java	1066
metadata/src/test/java/org/apache/kafka/controller/PartitionReassignmentReplicasTest.java	180
metadata/src/test/java/org/apache/kafka/controller/PartitionReassignmentRevertTest.java	94
metadata/src/test/java/org/apache/kafka/controller/PeriodicTaskControlManagerTest.java	255
metadata/src/test/java/org/apache/kafka/controller/ProducerIdControlManagerTest.java	124
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerIntegrationTestUtils.java	161
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerMetricsIntegrationTest.java	159
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java	1478
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTestEnv.java	161
metadata/src/test/java/org/apache/kafka/controller/QuorumFeaturesTest.java	89
metadata/src/test/java/org/apache/kafka/controller/ReplicationControlManagerTest.java	3047
metadata/src/test/java/org/apache/kafka/controller/ResultOrErrorTest.java	44
metadata/src/test/java/org/apache/kafka/controller/ScramCredentialValueTest.java	47
metadata/src/test/java/org/apache/kafka/controller/errors/ControllerExceptionsTest.java	75
metadata/src/test/java/org/apache/kafka/controller/errors/EventHandlerExceptionInfoTest.java	171
metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetadataMetricsPublisherTest.java	128
metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetadataMetricsTest.java	195
metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetricsChangesTest.java	136
metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetricsTestUtils.java	84
metadata/src/test/java/org/apache/kafka/controller/metrics/QuorumControllerMetricsTest.java	140
metadata/src/test/java/org/apache/kafka/image/AclsDeltaTest.java	88
metadata/src/test/java/org/apache/kafka/image/AclsImageTest.java	80
metadata/src/test/java/org/apache/kafka/image/ClientQuotasImageTest.java	99
metadata/src/test/java/org/apache/kafka/image/ClusterImageTest.java	266
metadata/src/test/java/org/apache/kafka/image/ConfigurationsImageTest.java	99
metadata/src/test/java/org/apache/kafka/image/DelegationTokenImageTest.java	111
metadata/src/test/java/org/apache/kafka/image/FakeSnapshotWriter.java	56
metadata/src/test/java/org/apache/kafka/image/FeaturesDeltaTest.java	28
metadata/src/test/java/org/apache/kafka/image/FeaturesImageTest.java	137
metadata/src/test/java/org/apache/kafka/image/ImageDowngradeTest.java	121
metadata/src/test/java/org/apache/kafka/image/MetadataImageTest.java	118
metadata/src/test/java/org/apache/kafka/image/MetadataVersionChangeTest.java	33
metadata/src/test/java/org/apache/kafka/image/ProducerIdsImageTest.java	79
metadata/src/test/java/org/apache/kafka/image/ScramImageTest.java	138
metadata/src/test/java/org/apache/kafka/image/TopicsImageTest.java	523
metadata/src/test/java/org/apache/kafka/image/loader/MetadataBatchLoaderTest.java	391
metadata/src/test/java/org/apache/kafka/image/loader/MetadataLoaderTest.java	736
metadata/src/test/java/org/apache/kafka/image/loader/metrics/MetadataLoaderMetricsTest.java	125
metadata/src/test/java/org/apache/kafka/image/node/ClientQuotasImageNodeTest.java	95
metadata/src/test/java/org/apache/kafka/image/node/ClusterImageBrokersNodeTest.java	53
metadata/src/test/java/org/apache/kafka/image/node/ClusterImageControllersNodeTest.java	46
metadata/src/test/java/org/apache/kafka/image/node/ClusterImageNodeTest.java	32
metadata/src/test/java/org/apache/kafka/image/node/ConfigurationImageNodeTest.java	48
metadata/src/test/java/org/apache/kafka/image/node/ConfigurationsImageNodeTest.java	58
metadata/src/test/java/org/apache/kafka/image/node/MetadataImageNodeTest.java	29
metadata/src/test/java/org/apache/kafka/image/node/ScramCredentialDataNodeTest.java	40
metadata/src/test/java/org/apache/kafka/image/node/TopicImageNodeTest.java	67
metadata/src/test/java/org/apache/kafka/image/node/printer/MetadataNodeRedactionCriteriaTest.java	88
metadata/src/test/java/org/apache/kafka/image/node/printer/NodeStringifierTest.java	32
metadata/src/test/java/org/apache/kafka/image/publisher/BrokerRegistrationTrackerTest.java	121
metadata/src/test/java/org/apache/kafka/image/publisher/ControllerRegistrationsPublisherTest.java	70
metadata/src/test/java/org/apache/kafka/image/publisher/SnapshotEmitterTest.java	124
metadata/src/test/java/org/apache/kafka/image/publisher/SnapshotGeneratorTest.java	190
metadata/src/test/java/org/apache/kafka/image/publisher/metrics/SnapshotEmitterMetricsTest.java	81
metadata/src/test/java/org/apache/kafka/image/writer/ImageReWriterTest.java	66
metadata/src/test/java/org/apache/kafka/image/writer/ImageWriterOptionsTest.java	90
metadata/src/test/java/org/apache/kafka/image/writer/RaftSnapshotWriterTest.java	36
metadata/src/test/java/org/apache/kafka/image/writer/RecordListWriterTest.java	36
metadata/src/test/java/org/apache/kafka/metadata/BrokerRegistrationFencingChangeTest.java	26
metadata/src/test/java/org/apache/kafka/metadata/BrokerRegistrationInControlledShutdownChangeTest.java	24
metadata/src/test/java/org/apache/kafka/metadata/BrokerRegistrationTest.java	195
metadata/src/test/java/org/apache/kafka/metadata/BrokerStateTest.java	18
metadata/src/test/java/org/apache/kafka/metadata/ConfigSynonymTest.java	26
metadata/src/test/java/org/apache/kafka/metadata/ControllerRegistrationTest.java	106
metadata/src/test/java/org/apache/kafka/metadata/DelegationTokenDataTest.java	86
metadata/src/test/java/org/apache/kafka/metadata/FakeKafkaConfigSchema.java	31
metadata/src/test/java/org/apache/kafka/metadata/KafkaConfigSchemaTest.java	135
metadata/src/test/java/org/apache/kafka/metadata/LeaderAndIsrTest.java	43
metadata/src/test/java/org/apache/kafka/metadata/LeaderRecoveryStateTest.java	61
metadata/src/test/java/org/apache/kafka/metadata/ListenerInfoTest.java	170
metadata/src/test/java/org/apache/kafka/metadata/MetadataRecordSerdeTest.java	163
metadata/src/test/java/org/apache/kafka/metadata/MockConfigRepository.java	39
metadata/src/test/java/org/apache/kafka/metadata/MockConfigRepositoryTest.java	31
metadata/src/test/java/org/apache/kafka/metadata/OptionalStringComparatorTest.java	18
metadata/src/test/java/org/apache/kafka/metadata/PartitionRegistrationTest.java	420
metadata/src/test/java/org/apache/kafka/metadata/RecordTestUtils.java	218
metadata/src/test/java/org/apache/kafka/metadata/ReplicasTest.java	96
metadata/src/test/java/org/apache/kafka/metadata/ScramCredentialDataTest.java	117
metadata/src/test/java/org/apache/kafka/metadata/VersionRangeTest.java	39
metadata/src/test/java/org/apache/kafka/metadata/authorizer/ClusterMetadataAuthorizerTest.java	192
metadata/src/test/java/org/apache/kafka/metadata/authorizer/MockAuthorizableRequestContext.java	120
metadata/src/test/java/org/apache/kafka/metadata/authorizer/StandardAclRecordIteratorTest.java	42
metadata/src/test/java/org/apache/kafka/metadata/authorizer/StandardAclTest.java	92
metadata/src/test/java/org/apache/kafka/metadata/authorizer/StandardAclWithIdTest.java	45
metadata/src/test/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerPropertyTest.java	235
metadata/src/test/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerTest.java	623
metadata/src/test/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectoryTest.java	66
metadata/src/test/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadataTest.java	100
metadata/src/test/java/org/apache/kafka/metadata/placement/PartitionAssignmentTest.java	52
metadata/src/test/java/org/apache/kafka/metadata/placement/StripedReplicaPlacerTest.java	251
metadata/src/test/java/org/apache/kafka/metadata/placement/TopicAssignmentTest.java	65
metadata/src/test/java/org/apache/kafka/metadata/properties/MetaPropertiesEnsembleTest.java	385
metadata/src/test/java/org/apache/kafka/metadata/properties/MetaPropertiesTest.java	150
metadata/src/test/java/org/apache/kafka/metadata/properties/MetaPropertiesVersionTest.java	67
metadata/src/test/java/org/apache/kafka/metadata/properties/PropertiesUtilsTest.java	67
metadata/src/test/java/org/apache/kafka/metadata/storage/FormatterTest.java	528
metadata/src/test/java/org/apache/kafka/metadata/storage/ScramParserTest.java	232
metadata/src/test/java/org/apache/kafka/metadata/util/BatchFileWriterReaderTest.java	77
metadata/src/test/java/org/apache/kafka/metadata/util/RecordRedactorTest.java	74
metadata/src/test/java/org/apache/kafka/metalog/LocalLogManager.java	610
metadata/src/test/java/org/apache/kafka/metalog/LocalLogManagerTest.java	128
metadata/src/test/java/org/apache/kafka/metalog/LocalLogManagerTestEnv.java	165
metadata/src/test/java/org/apache/kafka/metalog/MockMetaLogManagerListener.java	79
metadata/src/test/resources/log4j2.yaml	18
raft/src/test/java/org/apache/kafka/raft/CandidateStateTest.java	243
raft/src/test/java/org/apache/kafka/raft/ControlRecordTest.java	38
raft/src/test/java/org/apache/kafka/raft/DynamicVoterTest.java	145
raft/src/test/java/org/apache/kafka/raft/DynamicVotersTest.java	90
raft/src/test/java/org/apache/kafka/raft/ElectionStateTest.java	84
raft/src/test/java/org/apache/kafka/raft/EndpointsTest.java	266
raft/src/test/java/org/apache/kafka/raft/EpochElectionTest.java	101
raft/src/test/java/org/apache/kafka/raft/FileQuorumStateStoreTest.java	170
raft/src/test/java/org/apache/kafka/raft/FollowerStateTest.java	113
raft/src/test/java/org/apache/kafka/raft/KafkaNetworkChannelTest.java	322
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientClusterAuthTest.java	105
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientDriverTest.java	64
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientFetchTest.java	110
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientPreVoteTest.java	902
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java	2358
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java	1816
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java	3531
raft/src/test/java/org/apache/kafka/raft/LeaderStateTest.java	717
raft/src/test/java/org/apache/kafka/raft/MockExpirationService.java	52
raft/src/test/java/org/apache/kafka/raft/MockExpirationServiceTest.java	29
raft/src/test/java/org/apache/kafka/raft/MockLog.java	616
raft/src/test/java/org/apache/kafka/raft/MockLogTest.java	859
raft/src/test/java/org/apache/kafka/raft/MockMessageQueue.java	40
raft/src/test/java/org/apache/kafka/raft/MockNetworkChannel.java	60
raft/src/test/java/org/apache/kafka/raft/MockQuorumStateStore.java	27
raft/src/test/java/org/apache/kafka/raft/MockableRandom.java	25
raft/src/test/java/org/apache/kafka/raft/ProspectiveStateTest.java	399
raft/src/test/java/org/apache/kafka/raft/QuorumConfigTest.java	30
raft/src/test/java/org/apache/kafka/raft/QuorumStateTest.java	2319
raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java	1932
raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java	1166
raft/src/test/java/org/apache/kafka/raft/RaftUtilTest.java	590
raft/src/test/java/org/apache/kafka/raft/ReplicatedCounter.java	165
raft/src/test/java/org/apache/kafka/raft/RequestManagerTest.java	206
raft/src/test/java/org/apache/kafka/raft/ResignedStateTest.java	94
raft/src/test/java/org/apache/kafka/raft/UnattachedStateTest.java	161
raft/src/test/java/org/apache/kafka/raft/ValidOffsetAndEpochTest.java	27
raft/src/test/java/org/apache/kafka/raft/VoterSetTest.java	343
raft/src/test/java/org/apache/kafka/raft/internals/BatchAccumulatorTest.java	617
raft/src/test/java/org/apache/kafka/raft/internals/BatchBuilderTest.java	90
raft/src/test/java/org/apache/kafka/raft/internals/BatchMemoryPoolTest.java	92
raft/src/test/java/org/apache/kafka/raft/internals/BlockingMessageQueueTest.java	34
raft/src/test/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachineTest.java	350
raft/src/test/java/org/apache/kafka/raft/internals/KafkaRaftMetricsTest.java	399
raft/src/test/java/org/apache/kafka/raft/internals/MemoryBatchReaderTest.java	41
raft/src/test/java/org/apache/kafka/raft/internals/RecordsBatchReaderTest.java	114
raft/src/test/java/org/apache/kafka/raft/internals/RecordsIteratorTest.java	403
raft/src/test/java/org/apache/kafka/raft/internals/ThresholdPurgatoryTest.java	121
raft/src/test/java/org/apache/kafka/raft/internals/TimeRatioTest.java	37
raft/src/test/java/org/apache/kafka/raft/internals/TreeMapLogHistoryTest.java	76
raft/src/test/java/org/apache/kafka/raft/internals/VoterSetHistoryTest.java	174
raft/src/test/java/org/apache/kafka/snapshot/FileRawSnapshotTest.java	265
raft/src/test/java/org/apache/kafka/snapshot/MockRawSnapshotReader.java	38
raft/src/test/java/org/apache/kafka/snapshot/MockRawSnapshotWriter.java	72
raft/src/test/java/org/apache/kafka/snapshot/NotifyingRawSnapshotWriterTest.java	86
raft/src/test/java/org/apache/kafka/snapshot/RecordsSnapshotWriterTest.java	171
raft/src/test/java/org/apache/kafka/snapshot/SnapshotWriterReaderTest.java	223
raft/src/test/java/org/apache/kafka/snapshot/SnapshotsTest.java	84
raft/src/test/resources/log4j2.yaml	20
server-common/src/test/java/org/apache/kafka/common/DirectoryIdTest.java	62
server-common/src/test/java/org/apache/kafka/deferred/DeferredEventQueueTest.java	74
server-common/src/test/java/org/apache/kafka/metadata/AssignmentsHelperTest.java	71
server-common/src/test/java/org/apache/kafka/queue/KafkaEventQueueTest.java	368
server-common/src/test/java/org/apache/kafka/server/common/FeatureTest.java	255
server-common/src/test/java/org/apache/kafka/server/common/FinalizedFeaturesTest.java	31
server-common/src/test/java/org/apache/kafka/server/common/KRaftVersionTest.java	99
server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionTest.java	202
server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionTestUtils.java	6
server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionValidatorTest.java	11
server-common/src/test/java/org/apache/kafka/server/common/ProducerIdsBlockTest.java	46
server-common/src/test/java/org/apache/kafka/server/fault/LoggingFaultHandlerTest.java	25
server-common/src/test/java/org/apache/kafka/server/fault/MockFaultHandler.java	39
server-common/src/test/java/org/apache/kafka/server/fault/ProcessTerminatingFaultHandlerTest.java	59
server-common/src/test/java/org/apache/kafka/server/immutable/DelegationChecker.java	112
server-common/src/test/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableMapTest.java	256
server-common/src/test/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableNavigableSetTest.java	353
server-common/src/test/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableSetTest.java	217
server-common/src/test/java/org/apache/kafka/server/metrics/KafkaMetricsGroupTest.java	16
server-common/src/test/java/org/apache/kafka/server/metrics/KafkaYammerMetricsTest.java	60
server-common/src/test/java/org/apache/kafka/server/mutable/BoundedListTest.java	172
server-common/src/test/java/org/apache/kafka/server/network/EndpointReadyFuturesTest.java	139
server-common/src/test/java/org/apache/kafka/server/purgatory/DelayedOperationTest.java	260
server-common/src/test/java/org/apache/kafka/server/quota/QuotaUtilsTest.java	96
server-common/src/test/java/org/apache/kafka/server/record/BrokerCompressionTypeTest.java	30
server-common/src/test/java/org/apache/kafka/server/share/persister/DefaultStatePersisterTest.java	1429
server-common/src/test/java/org/apache/kafka/server/share/persister/PersisterStateManagerTest.java	3635
server-common/src/test/java/org/apache/kafka/server/util/CommandLineUtilsTest.java	211
server-common/src/test/java/org/apache/kafka/server/util/CsvTest.java	43
server-common/src/test/java/org/apache/kafka/server/util/DeadlineTest.java	43
server-common/src/test/java/org/apache/kafka/server/util/FileLockTest.java	72
server-common/src/test/java/org/apache/kafka/server/util/FutureUtilsTest.java	98
server-common/src/test/java/org/apache/kafka/server/util/InterBrokerSendThreadTest.java	276
server-common/src/test/java/org/apache/kafka/server/util/JsonTest.java	185
server-common/src/test/java/org/apache/kafka/server/util/MockRandom.java	16
server-common/src/test/java/org/apache/kafka/server/util/MockScheduler.java	121
server-common/src/test/java/org/apache/kafka/server/util/MockTime.java	16
server-common/src/test/java/org/apache/kafka/server/util/ShutdownableThreadTest.java	97
server-common/src/test/java/org/apache/kafka/server/util/TranslatedValueMapViewTest.java	82
server-common/src/test/java/org/apache/kafka/server/util/timer/MockTimer.java	64
server-common/src/test/java/org/apache/kafka/server/util/timer/SystemTimerReaperTest.java	43
server-common/src/test/java/org/apache/kafka/server/util/timer/TimerTaskListTest.java	74
server-common/src/test/java/org/apache/kafka/server/util/timer/TimerTest.java	114
server-common/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java	115
server-common/src/test/java/org/apache/kafka/timeline/SnapshotRegistryTest.java	89
server-common/src/test/java/org/apache/kafka/timeline/SnapshottableHashTableTest.java	246
server-common/src/test/java/org/apache/kafka/timeline/TimelineHashMapTest.java	87
server-common/src/test/java/org/apache/kafka/timeline/TimelineHashSetTest.java	79
server-common/src/test/java/org/apache/kafka/timeline/TimelineIntegerTest.java	63
server-common/src/test/java/org/apache/kafka/timeline/TimelineLongTest.java	63
server-common/src/test/java/org/apache/kafka/timeline/TimelineObjectTest.java	62
server-common/src/test/java/org/apache/kafka/timeline/TrackingSnapshotRegistry.java	30
server-common/src/test/resources/log4j2.yaml	18
server/src/test/java/org/apache/kafka/network/RequestConvertToJsonTest.java	102
server/src/test/java/org/apache/kafka/network/SocketServerConfigsTest.java	70
server/src/test/java/org/apache/kafka/security/authorizer/AuthorizerUtilsTest.java	106
server/src/test/java/org/apache/kafka/server/AssignmentTest.java	97
server/src/test/java/org/apache/kafka/server/AssignmentsManagerDeadlineFunctionTest.java	54
server/src/test/java/org/apache/kafka/server/AssignmentsManagerTest.java	454
server/src/test/java/org/apache/kafka/server/BootstrapControllersIntegrationTest.java	308
server/src/test/java/org/apache/kafka/server/BrokerFeaturesTest.java	87
server/src/test/java/org/apache/kafka/server/ClientMetricsManagerTest.java	985
server/src/test/java/org/apache/kafka/server/LogManagerIntegrationTest.java	94
server/src/test/java/org/apache/kafka/server/MonitorablePluginsIntegrationTest.java	117
server/src/test/java/org/apache/kafka/server/config/DelegationTokenManagerConfigsTest.java	55
server/src/test/java/org/apache/kafka/server/metrics/BrokerServerMetricsTest.java	111
server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsInstanceMetadataTest.java	97
server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsInstanceTest.java	53
server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsReceiverPluginTest.java	35
server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsTestUtils.java	80
server/src/test/java/org/apache/kafka/server/metrics/ForwardingManagerMetricsTest.java	100
server/src/test/java/org/apache/kafka/server/metrics/LinuxIoMetricsCollectorTest.java	57
server/src/test/java/org/apache/kafka/server/purgatory/DelayedFutureTest.java	84
server/src/test/java/org/apache/kafka/server/quota/ThrottledChannelTest.java	31
server/src/test/java/org/apache/kafka/server/share/CachedSharePartitionTest.java	32
server/src/test/java/org/apache/kafka/server/share/fetch/DelayedShareFetchKeyTest.java	35
server/src/test/java/org/apache/kafka/server/share/fetch/PartitionMaxBytesStrategyTest.java	56
server/src/test/java/org/apache/kafka/server/share/fetch/PartitionRotateStrategyTest.java	59
server/src/test/java/org/apache/kafka/server/share/fetch/ShareFetchTest.java	188
server/src/test/java/org/apache/kafka/server/share/fetch/ShareFetchTestUtils.java	79
server/src/test/java/org/apache/kafka/server/share/session/ShareSessionCacheTest.java	123
server/src/test/java/org/apache/kafka/server/share/session/ShareSessionTest.java	27
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/PersisterStateBatchCombinerTest.java	382
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorOffsetsManagerTest.java	161
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorRecordHelpersTest.java	112
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorRecordSerdeTest.java	181
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorServiceTest.java	1732
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorShardTest.java	1350
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorTestConfig.java	45
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/metrics/ShareCoordinatorMetricsTest.java	88
shell/src/test/java/org/apache/kafka/shell/MetadataShellIntegrationTest.java	94
shell/src/test/java/org/apache/kafka/shell/command/CommandTest.java	46
shell/src/test/java/org/apache/kafka/shell/command/CommandUtilsTest.java	23
shell/src/test/java/org/apache/kafka/shell/command/LsCommandHandlerTest.java	73
shell/src/test/java/org/apache/kafka/shell/glob/GlobComponentTest.java	52
shell/src/test/java/org/apache/kafka/shell/glob/GlobVisitorTest.java	158
shell/src/test/resources/log4j2.yaml	15
storage/api/src/test/java/org/apache/kafka/server/log/remote/storage/LogSegmentDataTest.java	32
storage/api/src/test/java/org/apache/kafka/server/log/remote/storage/NoOpRemoteLogMetadataManager.java	63
storage/api/src/test/java/org/apache/kafka/server/log/remote/storage/NoOpRemoteStorageManager.java	38
storage/api/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadataTest.java	51
storage/src/test/java/org/apache/kafka/server/log/LogAppendTimeTest.java	104
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/ClassLoaderAwareRemoteLogMetadataManagerTest.java	28
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTaskTest.java	381
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogLeaderEpochStateTest.java	154
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCacheTest.java	119
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataFormatterTest.java	55
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataManagerTestUtils.java	71
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataSerdeTest.java	80
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataTransformTest.java	59
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogSegmentLifecycleTest.java	242
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerConfigTest.java	140
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest.java	119
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerRestartTest.java	83
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerTest.java	243
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataSnapshotTransformTest.java	39
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataTransformTest.java	40
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogSegmentMetadataUpdateTransformTest.java	40
storage/src/test/java/org/apache/kafka/server/log/remote/quota/RLMQuotaManagerTest.java	73
storage/src/test/java/org/apache/kafka/server/log/remote/storage/ClassLoaderAwareRemoteStorageManagerTest.java	24
storage/src/test/java/org/apache/kafka/server/log/remote/storage/LocalTieredStorage.java	367
storage/src/test/java/org/apache/kafka/server/log/remote/storage/LocalTieredStorageCondition.java	104
storage/src/test/java/org/apache/kafka/server/log/remote/storage/LocalTieredStorageEvent.java	114
storage/src/test/java/org/apache/kafka/server/log/remote/storage/LocalTieredStorageHistory.java	53
storage/src/test/java/org/apache/kafka/server/log/remote/storage/LocalTieredStorageListener.java	26
storage/src/test/java/org/apache/kafka/server/log/remote/storage/LocalTieredStorageSnapshot.java	63
storage/src/test/java/org/apache/kafka/server/log/remote/storage/LocalTieredStorageTest.java	464
storage/src/test/java/org/apache/kafka/server/log/remote/storage/LocalTieredStorageTraverser.java	6
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfigTest.java	96
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerTest.java	3055
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManagerTest.java	101
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogOffsetReaderTest.java	154
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogReaderTest.java	89
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentFileset.java	172
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteTopicPartitionDirectory.java	101
storage/src/test/java/org/apache/kafka/server/log/remote/storage/RemoteTopicPartitionDirectoryTest.java	25
storage/src/test/java/org/apache/kafka/server/log/remote/storage/Transferer.java	8
storage/src/test/java/org/apache/kafka/server/purgatory/DelayedRemoteListOffsetsTest.java	213
storage/src/test/java/org/apache/kafka/storage/internals/checkpoint/CleanShutdownFileHandlerTest.java	55
storage/src/test/java/org/apache/kafka/storage/internals/checkpoint/LeaderEpochCheckpointFileWithFailureHandlerTest.java	39
storage/src/test/java/org/apache/kafka/storage/internals/checkpoint/OffsetCheckpointFileWithFailureHandlerTest.java	103
storage/src/test/java/org/apache/kafka/storage/internals/checkpoint/PartitionMetadataFileTest.java	64
storage/src/test/java/org/apache/kafka/storage/internals/log/BrokerCompressionTest.java	77
storage/src/test/java/org/apache/kafka/storage/internals/log/LocalLogTest.java	603
storage/src/test/java/org/apache/kafka/storage/internals/log/LogManagerTest.java	142
storage/src/test/java/org/apache/kafka/storage/internals/log/LogOffsetMetadataTest.java	55
storage/src/test/java/org/apache/kafka/storage/internals/log/LogSegmentTest.java	653
storage/src/test/java/org/apache/kafka/storage/internals/log/LogSegmentsTest.java	200
storage/src/test/java/org/apache/kafka/storage/internals/log/LogTestUtils.java	14
storage/src/test/java/org/apache/kafka/storage/internals/log/LogValidatorTest.java	1784
storage/src/test/java/org/apache/kafka/storage/internals/log/OffsetIndexTest.java	212
storage/src/test/java/org/apache/kafka/storage/internals/log/OffsetMapTest.java	80
storage/src/test/java/org/apache/kafka/storage/internals/log/ProducerStateManagerTest.java	1021
storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java	957
storage/src/test/java/org/apache/kafka/storage/internals/log/TimeIndexTest.java	147
storage/src/test/java/org/apache/kafka/storage/internals/log/TransactionIndexTest.java	170
storage/src/test/java/org/apache/kafka/storage/internals/log/UnifiedLogTest.java	14
storage/src/test/java/org/apache/kafka/storage/internals/log/VerificationGuardTest.java	29
storage/src/test/java/org/apache/kafka/storage/internals/utils/ThrottlerTest.java	70
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestAction.java	15
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestBuilder.java	362
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestContext.java	292
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestHarness.java	120
storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestReport.java	46
storage/src/test/java/org/apache/kafka/tiered/storage/actions/AlterLogDirAction.java	50
storage/src/test/java/org/apache/kafka/tiered/storage/actions/BounceBrokerAction.java	18
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ConsumeAction.java	168
storage/src/test/java/org/apache/kafka/tiered/storage/actions/CreatePartitionsAction.java	20
storage/src/test/java/org/apache/kafka/tiered/storage/actions/CreateTopicAction.java	28
storage/src/test/java/org/apache/kafka/tiered/storage/actions/DeleteRecordsAction.java	58
storage/src/test/java/org/apache/kafka/tiered/storage/actions/DeleteTopicAction.java	57
storage/src/test/java/org/apache/kafka/tiered/storage/actions/EraseBrokerStorageAction.java	30
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectBrokerInISRAction.java	34
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectEmptyRemoteStorageAction.java	24
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectLeaderAction.java	85
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectLeaderEpochCheckpointAction.java	48
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectListOffsetsAction.java	45
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectTopicIdToMatchInRemoteStorageAction.java	36
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectUserTopicMappedToMetadataPartitionsAction.java	48
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ProduceAction.java	102
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ReassignReplicaAction.java	51
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ShrinkReplicaAction.java	56
storage/src/test/java/org/apache/kafka/tiered/storage/actions/StartBrokerAction.java	18
storage/src/test/java/org/apache/kafka/tiered/storage/actions/StopBrokerAction.java	18
storage/src/test/java/org/apache/kafka/tiered/storage/actions/UpdateBrokerConfigAction.java	30
storage/src/test/java/org/apache/kafka/tiered/storage/actions/UpdateTopicConfigAction.java	30
storage/src/test/java/org/apache/kafka/tiered/storage/integration/AlterLogDirTest.java	38
storage/src/test/java/org/apache/kafka/tiered/storage/integration/BaseDeleteSegmentsTest.java	42
storage/src/test/java/org/apache/kafka/tiered/storage/integration/BaseReassignReplicaTest.java	54
storage/src/test/java/org/apache/kafka/tiered/storage/integration/DeleteSegmentsByRetentionSizeTest.java	9
storage/src/test/java/org/apache/kafka/tiered/storage/integration/DeleteSegmentsByRetentionTimeTest.java	9
storage/src/test/java/org/apache/kafka/tiered/storage/integration/DeleteSegmentsDueToLogStartOffsetBreachTest.java	57
storage/src/test/java/org/apache/kafka/tiered/storage/integration/DeleteTopicTest.java	49
storage/src/test/java/org/apache/kafka/tiered/storage/integration/DisableRemoteLogOnTopicTest.java	80
storage/src/test/java/org/apache/kafka/tiered/storage/integration/EnableRemoteLogOnTopicTest.java	53
storage/src/test/java/org/apache/kafka/tiered/storage/integration/FetchFromLeaderWithCorruptedCheckpointTest.java	52
storage/src/test/java/org/apache/kafka/tiered/storage/integration/ListOffsetsTest.java	78
storage/src/test/java/org/apache/kafka/tiered/storage/integration/OffloadAndConsumeFromLeaderTest.java	47
storage/src/test/java/org/apache/kafka/tiered/storage/integration/OffloadAndTxnConsumeFromLeaderTest.java	61
storage/src/test/java/org/apache/kafka/tiered/storage/integration/PartitionsExpandTest.java	64
storage/src/test/java/org/apache/kafka/tiered/storage/integration/ReassignReplicaExpandTest.java	8
storage/src/test/java/org/apache/kafka/tiered/storage/integration/ReassignReplicaMoveTest.java	8
storage/src/test/java/org/apache/kafka/tiered/storage/integration/ReassignReplicaShrinkTest.java	59
storage/src/test/java/org/apache/kafka/tiered/storage/integration/RollAndOffloadActiveSegmentTest.java	42
storage/src/test/java/org/apache/kafka/tiered/storage/integration/TransactionsWithTieredStoreTest.java	90
storage/src/test/java/org/apache/kafka/tiered/storage/specs/ConsumableSpec.java	44
storage/src/test/java/org/apache/kafka/tiered/storage/specs/DeletableSpec.java	45
storage/src/test/java/org/apache/kafka/tiered/storage/specs/ExpandPartitionCountSpec.java	43
storage/src/test/java/org/apache/kafka/tiered/storage/specs/FetchableSpec.java	35
storage/src/test/java/org/apache/kafka/tiered/storage/specs/KeyValueSpec.java	48
storage/src/test/java/org/apache/kafka/tiered/storage/specs/OffloadableSpec.java	46
storage/src/test/java/org/apache/kafka/tiered/storage/specs/OffloadedSegmentSpec.java	51
storage/src/test/java/org/apache/kafka/tiered/storage/specs/ProducableSpec.java	52
storage/src/test/java/org/apache/kafka/tiered/storage/specs/RemoteDeleteSegmentSpec.java	50
storage/src/test/java/org/apache/kafka/tiered/storage/specs/RemoteFetchCount.java	106
storage/src/test/java/org/apache/kafka/tiered/storage/specs/RemoteFetchSpec.java	42
storage/src/test/java/org/apache/kafka/tiered/storage/specs/TopicSpec.java	66
storage/src/test/java/org/apache/kafka/tiered/storage/utils/BrokerLocalStorage.java	168
storage/src/test/java/org/apache/kafka/tiered/storage/utils/DumpLocalTieredStorage.java	10
storage/src/test/java/org/apache/kafka/tiered/storage/utils/LocalTieredStorageOutput.java	73
storage/src/test/java/org/apache/kafka/tiered/storage/utils/RecordsKeyValueMatcher.java	118
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java	117
storage/src/test/resources/log4j2.yaml	38
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java	233
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/AdjustStreamThreadCountTest.java	416
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ConsistencyVectorIntegrationTest.java	171
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java	115
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EmitOnChangeIntegrationTest.java	140
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java	1068
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/FineGrainedAutoResetIntegrationTest.java	346
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ForeignKeyJoinSuite.java	23
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java	457
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalKTableIntegrationTest.java	341
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalStateReprocessTest.java	156
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java	177
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/HandlingSourceTopicDeletionIntegrationTest.java	93
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/HighAvailabilityTaskAssignorIntegrationTest.java	279
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2EndpointToPartitionsIntegrationTest.java	222
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2IntegrationTest.java	380
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java	1744
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2VersionedStoreIntegrationTest.java	286
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java	195
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/JoinGracePeriodDurabilityIntegrationTest.java	177
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/JoinStoreIntegrationTest.java	143
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/JoinWithIncompleteMetadataIntegrationTest.java	77
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationDedupIntegrationTest.java	213
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java	978
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamKStreamIntegrationTest.java	142
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamRepartitionIntegrationTest.java	684
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableEfficientRangeQueryTest.java	188
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest.java	270
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java	226
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinDistributedTest.java	185
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java	1093
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializationIntegrationTest.java	139
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableSourceTopicRestartIntegrationTest.java	186
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsCloseOptionsIntegrationTest.java	145
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java	503
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsWrapper.java	26
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java	298
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java	682
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/MetricsReporterIntegrationTest.java	88
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java	612
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java	174
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/PauseResumeIntegrationTest.java	330
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/PositionRestartIntegrationTest.java	595
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ProcessingExceptionHandlerIntegrationTest.java	382
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.java	177
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java	1086
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RangeQueryIntegrationTest.java	232
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RebalanceIntegrationTest.java	168
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java	391
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RelaxedNullKeyRequirementJoinTest.java	121
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ResetPartitionTimeIntegrationTest.java	148
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java	687
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RocksDBMetricsIntegrationTest.java	268
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SelfJoinUpgradeIntegrationTest.java	218
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SlidingWindowedKStreamIntegrationTest.java	400
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SmokeTestDriverIntegrationTest.java	143
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StandbyTaskCreationIntegrationTest.java	157
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java	312
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSMultiRebalanceIntegrationTest.java	240
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StateDirectoryIntegrationTest.java	196
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java	520
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StoreQuerySuite.java	21
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StoreUpgradeIntegrationTest.java	856
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java	461
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinIntegrationTest.java	169
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinTopologyOptimizationIntegrationTest.java	201
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinWithGraceIntegrationTest.java	103
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamsUncaughtExceptionHandlerIntegrationTest.java	336
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamsUpgradeTestIntegrationTest.java	99
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SuppressionDurabilityIntegrationTest.java	247
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java	444
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SwallowUnknownTopicErrorIntegrationTest.java	151
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java	953
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TaskAssignorIntegrationTest.java	113
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TaskMetadataIntegrationTest.java	159
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TestTaskAssignor.java	22
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TestingMetricsInterceptingAdminClient.java	421
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TimeWindowedKStreamIntegrationTest.java	418
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/VersionedKeyValueStoreIntegrationTest.java	589
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/CompositeStateListener.java	21
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java	332
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java	977
streams/integration-tests/src/test/resources/log4j2.yaml	38
streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala	86
streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/WordCountTest.scala	169
streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils/StreamToTableJoinScalaIntegrationTestBase.scala	101
streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils/StreamToTableJoinTestData.scala	35
streams/src/test/java/org/apache/kafka/common/metrics/SensorAccessor.java	11
streams/src/test/java/org/apache/kafka/streams/AutoOffsetResetTest.java	57
streams/src/test/java/org/apache/kafka/streams/EqualityCheck.java	104
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java	1638
streams/src/test/java/org/apache/kafka/streams/KeyValueTest.java	42
streams/src/test/java/org/apache/kafka/streams/KeyValueTimestamp.java	38
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java	2477
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java	1408
streams/src/test/java/org/apache/kafka/streams/TopologyTest.java	2143
streams/src/test/java/org/apache/kafka/streams/TopologyTestDriverWrapper.java	31
streams/src/test/java/org/apache/kafka/streams/TopologyWrapper.java	14
streams/src/test/java/org/apache/kafka/streams/internals/ApiUtilsTest.java	72
streams/src/test/java/org/apache/kafka/streams/internals/metrics/ClientMetricsTest.java	161
streams/src/test/java/org/apache/kafka/streams/internals/metrics/StreamsClientMetricsDelegatingReporterTest.java	71
streams/src/test/java/org/apache/kafka/streams/internals/metrics/StreamsThreadMetricsDelegatingReporterTest.java	84
streams/src/test/java/org/apache/kafka/streams/kstream/JoinWindowsTest.java	166
streams/src/test/java/org/apache/kafka/streams/kstream/MaterializedTest.java	72
streams/src/test/java/org/apache/kafka/streams/kstream/NamedTest.java	25
streams/src/test/java/org/apache/kafka/streams/kstream/PrintedTest.java	96
streams/src/test/java/org/apache/kafka/streams/kstream/RepartitionTopicNamingTest.java	572
streams/src/test/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializerTest.java	79
streams/src/test/java/org/apache/kafka/streams/kstream/SessionWindowedSerializerTest.java	79
streams/src/test/java/org/apache/kafka/streams/kstream/SessionWindowsTest.java	74
streams/src/test/java/org/apache/kafka/streams/kstream/SlidingWindowsTest.java	65
streams/src/test/java/org/apache/kafka/streams/kstream/SuppressedTest.java	169
streams/src/test/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializerTest.java	130
streams/src/test/java/org/apache/kafka/streams/kstream/TimeWindowedSerializerTest.java	79
streams/src/test/java/org/apache/kafka/streams/kstream/TimeWindowsTest.java	127
streams/src/test/java/org/apache/kafka/streams/kstream/UnlimitedWindowsTest.java	52
streams/src/test/java/org/apache/kafka/streams/kstream/WindowTest.java	58
streams/src/test/java/org/apache/kafka/streams/kstream/WindowedSerdesTest.java	129
streams/src/test/java/org/apache/kafka/streams/kstream/internals/AbstractStreamTest.java	87
streams/src/test/java/org/apache/kafka/streams/kstream/internals/ChangedSerdeTest.java	123
streams/src/test/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImplTest.java	1074
streams/src/test/java/org/apache/kafka/streams/kstream/internals/FullChangeSerdeTest.java	80
streams/src/test/java/org/apache/kafka/streams/kstream/internals/GlobalKTableJoinsTest.java	72
streams/src/test/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilderTest.java	985
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImplTest.java	659
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImplTest.java	321
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFilterTest.java	61
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapTest.java	69
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValuesTest.java	81
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamForeachTest.java	63
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoinTest.java	168
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableLeftJoinTest.java	178
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java	2221
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplValueJoinerWithKeyTest.java	184
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java	1175
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamLeftJoinTest.java	780
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamOuterJoinTest.java	896
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamSelfJoinTest.java	277
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinTest.java	411
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableLeftJoinTest.java	140
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamMapTest.java	63
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamMapValuesTest.java	60
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamPeekTest.java	53
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamPrintTest.java	57
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamProcessorApiTest.java	93
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamRepartitionTest.java	130
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSelectKeyTest.java	56
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregateProcessorTest.java	521
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java	1522
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSplitTest.java	113
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregateTest.java	1002
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableAggregateTest.java	433
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableFilterTest.java	421
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java	490
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableForeignKeyJoinScenarioTest.java	294
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoinTest.java	327
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinTest.java	373
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoinTest.java	302
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoinTest.java	43
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapKeysTest.java	50
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapValuesTest.java	246
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableReduceTest.java	54
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java	286
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableTransformValuesTest.java	471
streams/src/test/java/org/apache/kafka/streams/kstream/internals/MaterializedInternalTest.java	112
streams/src/test/java/org/apache/kafka/streams/kstream/internals/NamedInternalTest.java	46
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionCacheFlushListenerTest.java	33
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowTest.java	69
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImplTest.java	274
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java	377
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImplTest.java	196
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImplTest.java	386
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressScenarioTest.java	746
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressTopologyTest.java	204
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowTest.java	79
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImplTest.java	259
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImplTest.java	425
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimestampedCacheFlushListenerTest.java	51
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimestampedTupleForwarderTest.java	81
streams/src/test/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindowTest.java	19
streams/src/test/java/org/apache/kafka/streams/kstream/internals/WindowedStreamPartitionerTest.java	52
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchemaTest.java	62
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignTableJoinProcessorSupplierTests.java	154
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ResponseJoinProcessorSupplierTest.java	226
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionJoinProcessorSupplierTest.java	334
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionReceiveProcessorSupplierTest.java	455
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java	122
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java	530
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java	224
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/GraphGraceSearchUtilTest.java	224
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphTest.java	404
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNodeTest.java	59
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorMetricsTest.java	175
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorTest.java	377
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/SuppressSuite.java	24
streams/src/test/java/org/apache/kafka/streams/processor/FailOnInvalidTimestampTest.java	17
streams/src/test/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestampTest.java	35
streams/src/test/java/org/apache/kafka/streams/processor/ReadOnlyStoreTest.java	98
streams/src/test/java/org/apache/kafka/streams/processor/TimestampExtractorTest.java	28
streams/src/test/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestampTest.java	32
streams/src/test/java/org/apache/kafka/streams/processor/WallclockTimestampExtractorTest.java	34
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.java	220
streams/src/test/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreatorTest.java	235
streams/src/test/java/org/apache/kafka/streams/processor/internals/ChangelogTopicsTest.java	165
streams/src/test/java/org/apache/kafka/streams/processor/internals/ClientUtilsTest.java	223
streams/src/test/java/org/apache/kafka/streams/processor/internals/CopartitionedTopicsEnforcerTest.java	157
streams/src/test/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdaterTest.java	1589
streams/src/test/java/org/apache/kafka/streams/processor/internals/DefaultStreamsRebalanceListenerTest.java	168
streams/src/test/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContextTest.java	23
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImplTest.java	179
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java	1029
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateTaskTest.java	283
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java	359
streams/src/test/java/org/apache/kafka/streams/processor/internals/HighAvailabilityStreamsPartitionAssignorTest.java	244
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicConfigTest.java	95
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java	1679
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java	1223
streams/src/test/java/org/apache/kafka/streams/processor/internals/KeyValueStoreMaterializerTest.java	214
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockChangelogReader.java	62
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockStreamsMetrics.java	9
streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java	336
streams/src/test/java/org/apache/kafka/streams/processor/internals/PartitionGroupTest.java	804
streams/src/test/java/org/apache/kafka/streams/processor/internals/PartitionGrouperTest.java	71
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java	739
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java	54
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorMetadataTest.java	117
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java	303
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContextTest.java	81
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java	1014
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyFactories.java	32
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java	1070
streams/src/test/java/org/apache/kafka/streams/processor/internals/PunctuationQueueTest.java	104
streams/src/test/java/org/apache/kafka/streams/processor/internals/QuickUnionTest.java	61
streams/src/test/java/org/apache/kafka/streams/processor/internals/RackAwarenessStreamsPartitionAssignorTest.java	453
streams/src/test/java/org/apache/kafka/streams/processor/internals/ReadOnlyTaskTest.java	174
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java	1768
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordDeserializerTest.java	260
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordQueueTest.java	397
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionOptimizingTest.java	376
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfigTest.java	32
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionTopicsTest.java	387
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionWithMergeOptimizingTest.java	233
streams/src/test/java/org/apache/kafka/streams/processor/internals/SinkNodeTest.java	84
streams/src/test/java/org/apache/kafka/streams/processor/internals/SourceNodeTest.java	141
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java	462
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateConsumerTest.java	111
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java	805
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerStub.java	46
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java	185
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateRestoreCallbackAdapterTest.java	112
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java	1131
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java	2812
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java	3400
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTotalBlockedTimeTest.java	85
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsAssignmentScaleTest.java	251
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsMetadataStateTest.java	330
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java	2328
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsProducerTest.java	751
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListenerTest.java	121
streams/src/test/java/org/apache/kafka/streams/processor/internals/SynchronizedPartitionGroupTest.java	138
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskAndActionTest.java	57
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadataTest.java	80
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskExecutorTest.java	35
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java	4142
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskMetadataImplTest.java	123
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskSuite.java	17
streams/src/test/java/org/apache/kafka/streams/processor/internals/TasksTest.java	158
streams/src/test/java/org/apache/kafka/streams/processor/internals/ThreadMetadataImplTest.java	208
streams/src/test/java/org/apache/kafka/streams/processor/internals/TopicPartitionMetadataTest.java	68
streams/src/test/java/org/apache/kafka/streams/processor/internals/TopologyMetadataTest.java	52
streams/src/test/java/org/apache/kafka/streams/processor/internals/WriteConsistencyVectorTest.java	112
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfoTest.java	198
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentTestUtils.java	913
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfigurationTest.java	47
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientStateTest.java	477
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignorTest.java	697
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySetTest.java	73
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/CustomStickyTaskAssignorTest.java	800
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/FallbackPriorTaskAssignorTest.java	51
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/GraphTest.java	398
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java	1493
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/KafkaStreamsAssignmentTest.java	29
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/KafkaStreamsStateTest.java	67
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacyStickyTaskAssignorTest.java	1159
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacySubscriptionInfoSerde.java	220
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareGraphConstructorFactoryTest.java	24
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareGraphConstructorTest.java	240
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignorTest.java	1039
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignmentUtilsTest.java	101
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignorFactoryTest.java	76
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfoTest.java	440
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignmentUtilsTest.java	508
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignorConvergenceTest.java	525
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovementTest.java	260
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetricsTest.java	122
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImplTest.java	1165
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetricsTest.java	223
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetricsTest.java	416
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/TopicMetricsTest.java	83
streams/src/test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutorTest.java	191
streams/src/test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskManagerTest.java	347
streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/ConsumerRecordUtil.java	27
streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/DummyStreamsConfig.java	19
streams/src/test/java/org/apache/kafka/streams/query/MultiVersionedKeyQueryTest.java	11
streams/src/test/java/org/apache/kafka/streams/query/PositionBoundTest.java	63
streams/src/test/java/org/apache/kafka/streams/query/PositionTest.java	267
streams/src/test/java/org/apache/kafka/streams/query/StateQueryResultTest.java	36
streams/src/test/java/org/apache/kafka/streams/query/VersionedKeyQueryTest.java	18
streams/src/test/java/org/apache/kafka/streams/state/HostInfoTest.java	28
streams/src/test/java/org/apache/kafka/streams/state/KeyValueStoreTestDriver.java	199
streams/src/test/java/org/apache/kafka/streams/state/NoOpWindowStore.java	96
streams/src/test/java/org/apache/kafka/streams/state/StateSerdesTest.java	105
streams/src/test/java/org/apache/kafka/streams/state/StoresTest.java	266
streams/src/test/java/org/apache/kafka/streams/state/StreamsMetadataTest.java	113
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractDualSchemaRocksDBSegmentedBytesStoreTest.java	1362
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java	513
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStoreTest.java	718
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBWindowStoreTest.java	655
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractSessionBytesStoreTest.java	821
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractWindowBytesStoreTest.java	1029
streams/src/test/java/org/apache/kafka/streams/state/internals/BlockBasedTableConfigWithAccessibleCacheTest.java	30
streams/src/test/java/org/apache/kafka/streams/state/internals/BufferValueTest.java	162
streams/src/test/java/org/apache/kafka/streams/state/internals/CacheFlushListenerStub.java	27
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingInMemoryKeyValueStoreTest.java	536
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingInMemorySessionStoreTest.java	725
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingPersistentSessionStoreTest.java	757
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingPersistentWindowStoreTest.java	940
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.java	224
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStoreTest.java	142
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueBytesStoreTest.java	165
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesStoreTest.java	95
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingVersionedKeyValueBytesStoreTest.java	160
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStoreTest.java	108
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStoreTest.java	432
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStoreTest.java	156
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStoreTest.java	446
streams/src/test/java/org/apache/kafka/streams/state/internals/ContextualRecordTest.java	46
streams/src/test/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIteratorTest.java	68
streams/src/test/java/org/apache/kafka/streams/state/internals/FilteredCacheIteratorTest.java	88
streams/src/test/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProviderTest.java	203
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueLoggedStoreTest.java	21
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStoreTest.java	356
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryLRUCacheStoreTest.java	113
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemorySessionStoreTest.java	31
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueChangeBufferTest.java	39
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryWindowStoreTest.java	127
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueIteratorFacadeTest.java	50
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentTest.java	93
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentsTest.java	289
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilderTest.java	118
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreWrapperTest.java	240
streams/src/test/java/org/apache/kafka/streams/state/internals/LeftOrRightValueSerializerTest.java	44
streams/src/test/java/org/apache/kafka/streams/state/internals/ListValueStoreTest.java	149
streams/src/test/java/org/apache/kafka/streams/state/internals/LogicalKeyValueSegmentTest.java	393
streams/src/test/java/org/apache/kafka/streams/state/internals/LogicalKeyValueSegmentsTest.java	182
streams/src/test/java/org/apache/kafka/streams/state/internals/MaybeTest.java	48
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreIteratorTest.java	230
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedSessionStoreIteratorTest.java	115
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedWindowStoreIteratorTest.java	226
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest.java	219
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java	459
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredSessionStoreTest.java	600
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreTest.java	431
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStoreTest.java	221
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredVersionedKeyValueStoreTest.java	363
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreTest.java	416
streams/src/test/java/org/apache/kafka/streams/state/internals/MonotonicProcessorRecordContext.java	23
streams/src/test/java/org/apache/kafka/streams/state/internals/Murmur3Test.java	38
streams/src/test/java/org/apache/kafka/streams/state/internals/NamedCacheTest.java	195
streams/src/test/java/org/apache/kafka/streams/state/internals/OffsetCheckpointTest.java	132
streams/src/test/java/org/apache/kafka/streams/state/internals/QueryableStoreProviderTest.java	99
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyKeyValueStoreFacadeTest.java	75
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreFacadeTest.java	146
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreStub.java	353
streams/src/test/java/org/apache/kafka/streams/state/internals/RecordConvertersTest.java	29
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest.java	309
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBRangeIteratorTest.java	396
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStoreTest.java	18
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSessionStoreTest.java	7
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java	1081
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java	181
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBytesStoreTest.java	80
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionSchemaWithIndexSegmentedBytesStoreTest.java	7
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionSchemaWithoutIndexSegmentedBytesStoreTest.java	7
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionStoreWithIndexTest.java	7
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionStoreWithoutIndexTest.java	7
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowSchemaWithIndexSegmentedBytesStoreTest.java	7
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowSchemaWithoutIndexSegmentedBytesStoreTest.java	7
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStoreWithIndexTest.java	7
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStoreWithoutIndexTest.java	7
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedSegmentedBytesStoreTest.java	18
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStoreTest.java	351
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStoreSegmentValueFormatterTest.java	287
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStoreTest.java	758
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java	7
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDbIndexedTimeOrderedWindowBytesStoreSupplierTest.java	50
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDbVersionedKeyValueBytesStoreSupplierTest.java	31
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentIteratorTest.java	285
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentedCacheFunctionTest.java	85
streams/src/test/java/org/apache/kafka/streams/state/internals/SerdeThatDoesntHandleNull.java	33
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionKeySchemaTest.java	335
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionStoreBuilderTest.java	127
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionStoreFetchTest.java	261
streams/src/test/java/org/apache/kafka/streams/state/internals/StoreQueryUtilsTest.java	64
streams/src/test/java/org/apache/kafka/streams/state/internals/StoreSerdeInitializerTest.java	103
streams/src/test/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProviderTest.java	463
streams/src/test/java/org/apache/kafka/streams/state/internals/ThreadCacheTest.java	517
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingPersistentWindowStoreTest.java	1118
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferTest.java	869
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedWindowStoreTest.java	1128
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedKeyAndJoinSideSerializerTest.java	39
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilderTest.java	145
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedSegmentTest.java	99
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedSegmentsTest.java	290
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilderTest.java	201
streams/src/test/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializerTest.java	60
streams/src/test/java/org/apache/kafka/streams/state/internals/VersionedKeyValueStoreBuilderTest.java	117
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowKeySchemaTest.java	479
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreBuilderTest.java	149
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreFetchTest.java	243
streams/src/test/java/org/apache/kafka/streams/state/internals/WrappingStoreProviderTest.java	77
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetricsTest.java	46
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBBlockCacheMetricsTest.java	113
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderGaugesTest.java	212
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.java	511
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTriggerTest.java	61
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsTest.java	466
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetricsTest.java	344
streams/src/test/java/org/apache/kafka/streams/tests/BrokerCompatibilityTest.java	128
streams/src/test/java/org/apache/kafka/streams/tests/EosTestClient.java	128
streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java	524
streams/src/test/java/org/apache/kafka/streams/tests/RelationalSmokeTest.java	832
streams/src/test/java/org/apache/kafka/streams/tests/RelationalSmokeTestTest.java	75
streams/src/test/java/org/apache/kafka/streams/tests/ShutdownDeadlockTest.java	53
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	210
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	580
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/src/test/java/org/apache/kafka/streams/tests/StaticMemberTestClient.java	52
streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java	99
streams/src/test/java/org/apache/kafka/streams/tests/StreamsEosTest.java	58
streams/src/test/java/org/apache/kafka/streams/tests/StreamsNamedRepartitionTest.java	80
streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java	108
streams/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	70
streams/src/test/java/org/apache/kafka/streams/tests/StreamsStandByReplicaTest.java	122
streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	350
streams/src/test/java/org/apache/kafka/streams/tests/SystemTestUtil.java	25
streams/src/test/java/org/apache/kafka/streams/tests/SystemTestUtilTest.java	48
streams/src/test/java/org/apache/kafka/streams/utils/TestUtils.java	187
streams/src/test/java/org/apache/kafka/streams/utils/UniqueTopicSerdeScope.java	113
streams/src/test/java/org/apache/kafka/test/GenericInMemoryKeyValueStore.java	129
streams/src/test/java/org/apache/kafka/test/GenericInMemoryTimestampedKeyValueStore.java	131
streams/src/test/java/org/apache/kafka/test/GlobalStateManagerStub.java	78
streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java	451
streams/src/test/java/org/apache/kafka/test/KeyValueIteratorStub.java	25
streams/src/test/java/org/apache/kafka/test/MockAggregator.java	9
streams/src/test/java/org/apache/kafka/test/MockApiFixedKeyProcessor.java	117
streams/src/test/java/org/apache/kafka/test/MockApiFixedKeyProcessorSupplier.java	41
streams/src/test/java/org/apache/kafka/test/MockApiProcessor.java	122
streams/src/test/java/org/apache/kafka/test/MockApiProcessorSupplier.java	40
streams/src/test/java/org/apache/kafka/test/MockCachedKeyValueStore.java	18
streams/src/test/java/org/apache/kafka/test/MockClientSupplier.java	70
streams/src/test/java/org/apache/kafka/test/MockInitializer.java	11
streams/src/test/java/org/apache/kafka/test/MockInternalProcessorContext.java	209
streams/src/test/java/org/apache/kafka/test/MockInternalTopicManager.java	49
streams/src/test/java/org/apache/kafka/test/MockKeyValueStore.java	106
streams/src/test/java/org/apache/kafka/test/MockKeyValueStoreBuilder.java	21
streams/src/test/java/org/apache/kafka/test/MockMapper.java	61
streams/src/test/java/org/apache/kafka/test/MockPredicate.java	13
streams/src/test/java/org/apache/kafka/test/MockProcessor.java	63
streams/src/test/java/org/apache/kafka/test/MockProcessorNode.java	41
streams/src/test/java/org/apache/kafka/test/MockProcessorSupplier.java	40
streams/src/test/java/org/apache/kafka/test/MockRecordCollector.java	81
streams/src/test/java/org/apache/kafka/test/MockReducer.java	32
streams/src/test/java/org/apache/kafka/test/MockRestoreCallback.java	12
streams/src/test/java/org/apache/kafka/test/MockRestoreConsumer.java	107
streams/src/test/java/org/apache/kafka/test/MockRocksDbConfigSetter.java	17
streams/src/test/java/org/apache/kafka/test/MockSourceNode.java	35
streams/src/test/java/org/apache/kafka/test/MockStandbyUpdateListener.java	32
streams/src/test/java/org/apache/kafka/test/MockStateRestoreListener.java	66
streams/src/test/java/org/apache/kafka/test/MockTimestampExtractor.java	9
streams/src/test/java/org/apache/kafka/test/MockValueJoiner.java	8
streams/src/test/java/org/apache/kafka/test/NoOpProcessorContext.java	128
streams/src/test/java/org/apache/kafka/test/NoOpReadOnlyStore.java	80
streams/src/test/java/org/apache/kafka/test/NoOpValueTransformerWithKeySupplier.java	23
streams/src/test/java/org/apache/kafka/test/NoopValueTransformer.java	15
streams/src/test/java/org/apache/kafka/test/NoopValueTransformerWithKey.java	15
streams/src/test/java/org/apache/kafka/test/ReadOnlySessionStoreStub.java	165
streams/src/test/java/org/apache/kafka/test/StateStoreProviderStub.java	52
streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java	274
streams/src/test/resources/log4j2.yaml	38
streams/streams-scala/src/test/resources/log4j2.yaml	15
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/TopologyTest.scala	318
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/ConsumedTest.scala	48
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/GroupedTest.scala	24
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/JoinedTest.scala	22
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamSplitTest.scala	86
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamTest.scala	303
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KTableTest.scala	474
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/MaterializedTest.scala	59
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/ProducedTest.scala	38
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/RepartitionedTest.scala	80
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/StreamJoinedTest.scala	55
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/utils/TestDriver.scala	20
streams/test-utils/src/main/java/org/apache/kafka/streams/test/TestRecord.java	119
streams/test-utils/src/main/java/org/apache/kafka/streams/test/package-info.java	1
streams/test-utils/src/test/java/org/apache/kafka/streams/KeyValueStoreFacadeTest.java	101
streams/test-utils/src/test/java/org/apache/kafka/streams/MockProcessorContextTest.java	356
streams/test-utils/src/test/java/org/apache/kafka/streams/MockTimeTest.java	33
streams/test-utils/src/test/java/org/apache/kafka/streams/TestTopicsTest.java	381
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverAtLeastOnceTest.java	7
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverEosTest.java	7
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java	1484
streams/test-utils/src/test/java/org/apache/kafka/streams/WindowStoreFacadeTest.java	70
streams/test-utils/src/test/java/org/apache/kafka/streams/test/MockProcessorContextAPITest.java	273
streams/test-utils/src/test/java/org/apache/kafka/streams/test/MockProcessorContextStateStoreTest.java	163
streams/test-utils/src/test/java/org/apache/kafka/streams/test/TestRecordTest.java	128
streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessorSupplier.java	46
streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessorTest.java	121
streams/test-utils/src/test/resources/log4j2.yaml	18
streams/upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	66
streams/upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	52
streams/upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	66
streams/upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	101
streams/upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	66
streams/upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	101
streams/upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	56
streams/upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	101
streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	56
streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	101
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	231
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	513
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	96
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	56
streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	101
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	231
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	507
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	96
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	56
streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	90
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	231
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	96
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	85
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	231
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	96
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	85
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	231
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	96
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	85
streams/upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	231
streams/upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	563
streams/upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	96
streams/upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	85
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	96
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	85
streams/upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
streams/upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
streams/upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
streams/upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
streams/upgrade-system-tests-34/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-34/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-34/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-34/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-34/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
streams/upgrade-system-tests-35/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-35/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-35/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-35/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-35/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
streams/upgrade-system-tests-36/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-36/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-36/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-36/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-36/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
streams/upgrade-system-tests-37/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-37/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-37/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-37/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-37/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
streams/upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
streams/upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
streams/upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	232
streams/upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	553
streams/upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	93
streams/upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	60
streams/upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	86
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/AutoStart.java	6
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/ClusterConfig.java	234
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/ClusterConfigProperty.java	14
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/ClusterFeature.java	14
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/ClusterTemplate.java	18
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/ClusterTest.java	34
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/ClusterTestDefaults.java	17
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/ClusterTests.java	18
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/DetectThreadLeak.java	16
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/TestKitDefaults.java	12
test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/Type.java	4
test-common/test-common-internal-api/src/test/java/org/apache/kafka/common/test/api/ClusterConfigTest.java	90
test-common/test-common-internal-api/src/test/java/org/apache/kafka/common/test/api/DetectThreadLeakTest.java	43
test-common/test-common-internal-api/src/test/resources/log4j2.yaml	18
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/ClusterInstance.java	274
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/JaasModule.java	24
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/JaasUtils.java	39
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/KafkaClusterTestKit.java	598
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/KafkaClusterThreadFactory.java	23
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/MockController.java	478
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/MockFaultHandler.java	41
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/PreboundSocketFactoryManager.java	107
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/TestKitNode.java	21
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/TestKitNodes.java	316
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/TestUtils.java	138
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/junit/ClusterInstanceParameterResolver.java	31
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/junit/ClusterTestExtensions.java	203
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/junit/RaftClusterInvocationContext.java	243
test-common/test-common-runtime/src/test/java/org/apache/kafka/common/test/KafkaClusterTestKitTest.java	126
test-common/test-common-runtime/src/test/java/org/apache/kafka/common/test/KafkaClusterThreadFactoryTest.java	17
test-common/test-common-runtime/src/test/java/org/apache/kafka/common/test/TestKitNodeTest.java	37
test-common/test-common-runtime/src/test/java/org/apache/kafka/common/test/junit/ClusterTestBeforeEachTest.java	32
test-common/test-common-runtime/src/test/java/org/apache/kafka/common/test/junit/ClusterTestExtensionsTest.java	466
test-common/test-common-runtime/src/test/java/org/apache/kafka/common/test/junit/ClusterTestExtensionsUnitTest.java	50
test-common/test-common-util/src/main/java/org/apache/kafka/common/test/api/Flaky.java	13
test-common/test-common-util/src/main/java/org/apache/kafka/common/test/junit/CatalogTestFilter.java	102
test-common/test-common-util/src/main/java/org/apache/kafka/common/test/junit/KafkaPostDiscoveryFilter.java	85
test-common/test-common-util/src/test/java/org/apache/kafka/common/test/junit/CatalogTestFilterTest.java	49
test-common/test-common-util/src/test/java/org/apache/kafka/common/test/junit/KafkaPostDiscoveryFilterTest.java	154
tests/MANIFEST.in	15
tests/bootstrap-test-env.sh	57
tests/docker/run_tests.sh	24
tests/docker/ssh/id_rsa.pub	1
tests/kafkatest/__init__.py	1
tests/kafkatest/benchmarks/__init__.py	1
tests/kafkatest/benchmarks/core/__init__.py	1
tests/kafkatest/benchmarks/core/benchmark_test.py	195
tests/kafkatest/directory_layout/__init__.py	1
tests/kafkatest/directory_layout/kafka_path.py	71
tests/kafkatest/sanity_checks/__init__.py	1
tests/kafkatest/sanity_checks/test_bounce.py	42
tests/kafkatest/sanity_checks/test_console_consumer.py	38
tests/kafkatest/sanity_checks/test_performance_services.py	50
tests/kafkatest/sanity_checks/test_verifiable_producer.py	99
tests/kafkatest/services/__init__.py	1
tests/kafkatest/services/connect.py	431
tests/kafkatest/services/console_consumer.py	208
tests/kafkatest/services/consumer_property.py	2
tests/kafkatest/services/delegation_tokens.py	66
tests/kafkatest/services/kafka/__init__.py	3
tests/kafkatest/services/kafka/config.py	23
tests/kafkatest/services/kafka/config_property.py	55
tests/kafkatest/services/kafka/consumer_group.py	14
tests/kafkatest/services/kafka/kafka.py	1277
tests/kafkatest/services/kafka/quorum.py	37
tests/kafkatest/services/kafka/templates/log4j2.yaml	251
tests/kafkatest/services/kafka/util.py	21
tests/kafkatest/services/log_compaction_tester.py	57
tests/kafkatest/services/monitor/__init__.py	1
tests/kafkatest/services/monitor/http.py	134
tests/kafkatest/services/monitor/jmx.py	100
tests/kafkatest/services/performance/__init__.py	4
tests/kafkatest/services/performance/consumer_performance.py	85
tests/kafkatest/services/performance/end_to_end_latency.py	79
tests/kafkatest/services/performance/performance.py	34
tests/kafkatest/services/performance/producer_performance.py	119
tests/kafkatest/services/performance/templates/tools_log4j2.yaml	14
tests/kafkatest/services/replica_verification_tool.py	53
tests/kafkatest/services/security/__init__.py	1
tests/kafkatest/services/security/kafka_acls.py	23
tests/kafkatest/services/security/listener_security_config.py	11
tests/kafkatest/services/security/minikdc.py	82
tests/kafkatest/services/security/security_config.py	288
tests/kafkatest/services/streams.py	632
tests/kafkatest/services/streams_property.py	5
tests/kafkatest/services/templates/connect_log4j2.yaml	21
tests/kafkatest/services/templates/tools_log4j2.yaml	21
tests/kafkatest/services/transactional_message_copier.py	158
tests/kafkatest/services/trogdor/__init__.py	1
tests/kafkatest/services/trogdor/consume_bench_workload.py	32
tests/kafkatest/services/trogdor/degraded_network_fault_spec.py	10
tests/kafkatest/services/trogdor/files_unreadable_fault_spec.py	14
tests/kafkatest/services/trogdor/kibosh.py	87
tests/kafkatest/services/trogdor/network_partition_fault_spec.py	6
tests/kafkatest/services/trogdor/no_op_task_spec.py	5
tests/kafkatest/services/trogdor/process_stop_fault_spec.py	7
tests/kafkatest/services/trogdor/produce_bench_workload.py	32
tests/kafkatest/services/trogdor/round_trip_workload.py	25
tests/kafkatest/services/trogdor/task_spec.py	19
tests/kafkatest/services/trogdor/templates/log4j2.yaml	23
tests/kafkatest/services/trogdor/trogdor.py	204
tests/kafkatest/services/verifiable_client.py	97
tests/kafkatest/services/verifiable_consumer.py	394
tests/kafkatest/services/verifiable_producer.py	235
tests/kafkatest/services/verifiable_share_consumer.py	242
tests/kafkatest/services/zookeeper.py	201
tests/kafkatest/tests/__init__.py	1
tests/kafkatest/tests/client/__init__.py	1
tests/kafkatest/tests/client/client_compatibility_features_test.py	102
tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py	80
tests/kafkatest/tests/client/compression_test.py	45
tests/kafkatest/tests/client/consumer_protocol_migration_test.py	185
tests/kafkatest/tests/client/consumer_rolling_upgrade_test.py	50
tests/kafkatest/tests/client/consumer_test.py	328
tests/kafkatest/tests/client/pluggable_test.py	29
tests/kafkatest/tests/client/quota_test.py	155
tests/kafkatest/tests/client/share_consumer_test.py	209
tests/kafkatest/tests/client/truncation_test.py	97
tests/kafkatest/tests/connect/__init__.py	1
tests/kafkatest/tests/connect/connect_distributed_test.py	670
tests/kafkatest/tests/connect/connect_plugin_discovery_test.py	43
tests/kafkatest/tests/connect/connect_rest_test.py	166
tests/kafkatest/tests/connect/connect_test.py	137
tests/kafkatest/tests/core/__init__.py	1
tests/kafkatest/tests/core/authorizer_test.py	64
tests/kafkatest/tests/core/compatibility_test_new_broker_test.py	66
tests/kafkatest/tests/core/consume_bench_test.py	182
tests/kafkatest/tests/core/consumer_group_command_test.py	67
tests/kafkatest/tests/core/controller_mutation_quota_test.py	70
tests/kafkatest/tests/core/delegation_token_test.py	83
tests/kafkatest/tests/core/eligible_leader_replicas_test.py	113
tests/kafkatest/tests/core/fetch_from_follower_test.py	89
tests/kafkatest/tests/core/get_offset_shell_test.py	151
tests/kafkatest/tests/core/group_mode_transactions_test.py	231
tests/kafkatest/tests/core/log_dir_failure_test.py	103
tests/kafkatest/tests/core/network_degrade_test.py	85
tests/kafkatest/tests/core/produce_bench_test.py	61
tests/kafkatest/tests/core/quorum_reconfiguration_test.py	128
tests/kafkatest/tests/core/reassign_partitions_test.py	100
tests/kafkatest/tests/core/replica_scale_test.py	115
tests/kafkatest/tests/core/replication_replica_failure_test.py	61
tests/kafkatest/tests/core/replication_test.py	102
tests/kafkatest/tests/core/round_trip_fault_test.py	98
tests/kafkatest/tests/core/security_rolling_upgrade_test.py	110
tests/kafkatest/tests/core/security_test.py	102
tests/kafkatest/tests/core/snapshot_test.py	147
tests/kafkatest/tests/core/throttling_test.py	116
tests/kafkatest/tests/core/transactions_mixed_versions_test.py	163
tests/kafkatest/tests/core/transactions_test.py	187
tests/kafkatest/tests/core/transactions_upgrade_test.py	187
tests/kafkatest/tests/core/upgrade_test.py	132
tests/kafkatest/tests/end_to_end.py	111
tests/kafkatest/tests/kafka_test.py	18
tests/kafkatest/tests/produce_consume_validate.py	74
tests/kafkatest/tests/streams/__init__.py	1
tests/kafkatest/tests/streams/base_streams_test.py	94
tests/kafkatest/tests/streams/streams_application_upgrade_test.py	218
tests/kafkatest/tests/streams/streams_broker_bounce_test.py	174
tests/kafkatest/tests/streams/streams_broker_compatibility_test.py	62
tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py	247
tests/kafkatest/tests/streams/streams_eos_test.py	118
tests/kafkatest/tests/streams/streams_named_repartition_topic_test.py	57
tests/kafkatest/tests/streams/streams_optimized_test.py	101
tests/kafkatest/tests/streams/streams_relational_smoke_test.py	93
tests/kafkatest/tests/streams/streams_shutdown_deadlock_test.py	18
tests/kafkatest/tests/streams/streams_smoke_test.py	73
tests/kafkatest/tests/streams/streams_standby_replica_test.py	115
tests/kafkatest/tests/streams/streams_static_membership_test.py	69
tests/kafkatest/tests/streams/streams_upgrade_test.py	369
tests/kafkatest/tests/streams/templates/log4j2_template.yaml	21
tests/kafkatest/tests/streams/utils/__init__.py	1
tests/kafkatest/tests/streams/utils/util.py	25
tests/kafkatest/tests/tools/__init__.py	1
tests/kafkatest/tests/tools/kibosh_test.py	54
tests/kafkatest/tests/tools/log_compaction_test.py	36
tests/kafkatest/tests/tools/replica_verification_test.py	56
tests/kafkatest/tests/tools/trogdor_test.py	66
tests/kafkatest/tests/verifiable_consumer_test.py	64
tests/kafkatest/tests/verifiable_share_consumer_test.py	72
tests/kafkatest/utils/__init__.py	1
tests/kafkatest/utils/remote_account.py	30
tests/kafkatest/utils/transactions_utils.py	40
tests/kafkatest/utils/util.py	91
tests/kafkatest/version.py	125
tests/setup.cfg	6
tests/setup.py	30
tests/unit/__init__.py	1
tests/unit/directory_layout/__init__.py	1
tests/unit/directory_layout/check_project_paths.py	40
tests/unit/setup.cfg	4
tests/unit/version/__init__.py	1
tests/unit/version/check_version.py	12
tools/src/test/java/org/apache/kafka/tools/AbstractResetIntegrationTest.java	328
tools/src/test/java/org/apache/kafka/tools/AclCommandTest.java	508
tools/src/test/java/org/apache/kafka/tools/BrokerApiVersionsCommandTest.java	75
tools/src/test/java/org/apache/kafka/tools/ClientMetricsCommandTest.java	257
tools/src/test/java/org/apache/kafka/tools/ClusterToolTest.java	126
tools/src/test/java/org/apache/kafka/tools/ConfigCommandIntegrationTest.java	553
tools/src/test/java/org/apache/kafka/tools/ConfigCommandTest.java	1252
tools/src/test/java/org/apache/kafka/tools/ConnectPluginPathTest.java	562
tools/src/test/java/org/apache/kafka/tools/ConsoleProducerTest.java	196
tools/src/test/java/org/apache/kafka/tools/ConsumerPerformanceTest.java	100
tools/src/test/java/org/apache/kafka/tools/DelegationTokenCommandTest.java	67
tools/src/test/java/org/apache/kafka/tools/DeleteRecordsCommandTest.java	129
tools/src/test/java/org/apache/kafka/tools/EndToEndLatencyTest.java	74
tools/src/test/java/org/apache/kafka/tools/FeatureCommandTest.java	467
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellParsingTest.java	193
tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java	398
tools/src/test/java/org/apache/kafka/tools/GroupsCommandTest.java	574
tools/src/test/java/org/apache/kafka/tools/JmxToolTest.java	356
tools/src/test/java/org/apache/kafka/tools/LeaderElectionCommandErrorTest.java	69
tools/src/test/java/org/apache/kafka/tools/LeaderElectionCommandTest.java	271
tools/src/test/java/org/apache/kafka/tools/LineMessageReaderTest.java	316
tools/src/test/java/org/apache/kafka/tools/LogDirsCommandTest.java	181
tools/src/test/java/org/apache/kafka/tools/MetadataQuorumCommandErrorTest.java	57
tools/src/test/java/org/apache/kafka/tools/MetadataQuorumCommandTest.java	146
tools/src/test/java/org/apache/kafka/tools/MetadataQuorumCommandUnitTest.java	222
tools/src/test/java/org/apache/kafka/tools/ProducerPerformanceTest.java	420
tools/src/test/java/org/apache/kafka/tools/PushHttpMetricsReporterTest.java	272
tools/src/test/java/org/apache/kafka/tools/ReplicaVerificationToolTest.java	46
tools/src/test/java/org/apache/kafka/tools/ResetIntegrationTest.java	287
tools/src/test/java/org/apache/kafka/tools/ResetIntegrationWithSslTest.java	53
tools/src/test/java/org/apache/kafka/tools/ShareConsumerPerformanceTest.java	95
tools/src/test/java/org/apache/kafka/tools/StreamsResetterTest.java	238
tools/src/test/java/org/apache/kafka/tools/ToolsTestUtils.java	185
tools/src/test/java/org/apache/kafka/tools/TopicCommandTest.java	1224
tools/src/test/java/org/apache/kafka/tools/TransactionsCommandTest.java	948
tools/src/test/java/org/apache/kafka/tools/UserScramCredentialsCommandTest.java	137
tools/src/test/java/org/apache/kafka/tools/consumer/ConsoleConsumerOptionsTest.java	505
tools/src/test/java/org/apache/kafka/tools/consumer/ConsoleConsumerTest.java	384
tools/src/test/java/org/apache/kafka/tools/consumer/ConsoleShareConsumerOptionsTest.java	206
tools/src/test/java/org/apache/kafka/tools/consumer/ConsoleShareConsumerTest.java	115
tools/src/test/java/org/apache/kafka/tools/consumer/CoordinatorRecordMessageFormatterTest.java	44
tools/src/test/java/org/apache/kafka/tools/consumer/DefaultMessageFormatterTest.java	127
tools/src/test/java/org/apache/kafka/tools/consumer/GroupMetadataMessageFormatterTest.java	170
tools/src/test/java/org/apache/kafka/tools/consumer/NoOpMessageFormatterTest.java	20
tools/src/test/java/org/apache/kafka/tools/consumer/OffsetMessageFormatterTest.java	129
tools/src/test/java/org/apache/kafka/tools/consumer/ShareGroupMessageFormatterTest.java	224
tools/src/test/java/org/apache/kafka/tools/consumer/TransactionLogMessageFormatterTest.java	86
tools/src/test/java/org/apache/kafka/tools/consumer/group/AuthorizerIntegrationTest.java	29
tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandTest.java	33
tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandTestUtils.java	76
tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupServiceTest.java	257
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteConsumerGroupsTest.java	288
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteOffsetsConsumerGroupCommandIntegrationTest.java	231
tools/src/test/java/org/apache/kafka/tools/consumer/group/DescribeConsumerGroupTest.java	1063
tools/src/test/java/org/apache/kafka/tools/consumer/group/ListConsumerGroupTest.java	545
tools/src/test/java/org/apache/kafka/tools/consumer/group/ResetConsumerGroupOffsetTest.java	719
tools/src/test/java/org/apache/kafka/tools/consumer/group/SaslClientsWithInvalidCredentialsTest.java	151
tools/src/test/java/org/apache/kafka/tools/consumer/group/ShareGroupCommandTest.java	939
tools/src/test/java/org/apache/kafka/tools/consumer/group/share/ShareGroupStateMessageFormatterTest.java	205
tools/src/test/java/org/apache/kafka/tools/filter/TopicFilterTest.java	28
tools/src/test/java/org/apache/kafka/tools/other/ReplicationQuotasTestRig.java	377
tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommandArgsTest.java	263
tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommandTest.java	640
tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsUnitTest.java	619
tools/src/test/java/org/apache/kafka/tools/streams/DescribeStreamsGroupTest.java	178
tools/src/test/java/org/apache/kafka/tools/streams/StreamsGroupCommandTest.java	224
tools/src/test/resources/log4j2.yaml	20
tools/tools-api/src/test/java/org/apache/kafka/tools/api/RecordReaderTest.java	12
transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction/ProducerIdManagerTest.java	170
transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction/TransactionCoordinatorRecordSerdeTest.java	159
transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction/TransactionLogConfigTest.java	66
transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction/TransactionStateManagerConfigTest.java	48
trogdor/src/test/java/org/apache/kafka/trogdor/agent/AgentTest.java	413
trogdor/src/test/java/org/apache/kafka/trogdor/basic/BasicPlatformTest.java	41
trogdor/src/test/java/org/apache/kafka/trogdor/common/CapturingCommandRunner.java	34
trogdor/src/test/java/org/apache/kafka/trogdor/common/ExpectedTasks.java	168
trogdor/src/test/java/org/apache/kafka/trogdor/common/JsonSerializationTest.java	64
trogdor/src/test/java/org/apache/kafka/trogdor/common/JsonUtilTest.java	43
trogdor/src/test/java/org/apache/kafka/trogdor/common/MiniTrogdorCluster.java	222
trogdor/src/test/java/org/apache/kafka/trogdor/common/StringExpanderTest.java	47
trogdor/src/test/java/org/apache/kafka/trogdor/common/StringFormatterTest.java	36
trogdor/src/test/java/org/apache/kafka/trogdor/common/TopologyTest.java	41
trogdor/src/test/java/org/apache/kafka/trogdor/common/WorkerUtilsTest.java	267
trogdor/src/test/java/org/apache/kafka/trogdor/coordinator/CoordinatorClientTest.java	55
trogdor/src/test/java/org/apache/kafka/trogdor/coordinator/CoordinatorTest.java	616
trogdor/src/test/java/org/apache/kafka/trogdor/rest/RestExceptionMapperTest.java	78
trogdor/src/test/java/org/apache/kafka/trogdor/task/SampleTaskController.java	9
trogdor/src/test/java/org/apache/kafka/trogdor/task/SampleTaskSpec.java	36
trogdor/src/test/java/org/apache/kafka/trogdor/task/SampleTaskWorker.java	44
trogdor/src/test/java/org/apache/kafka/trogdor/task/TaskSpecTest.java	26
trogdor/src/test/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpecTest.java	49
trogdor/src/test/java/org/apache/kafka/trogdor/workload/ExternalCommandWorkerTest.java	138
trogdor/src/test/java/org/apache/kafka/trogdor/workload/HistogramTest.java	57
trogdor/src/test/java/org/apache/kafka/trogdor/workload/PayloadGeneratorTest.java	193
trogdor/src/test/java/org/apache/kafka/trogdor/workload/ShareConsumeBenchSpecTest.java	41
trogdor/src/test/java/org/apache/kafka/trogdor/workload/ThrottleTest.java	44
trogdor/src/test/java/org/apache/kafka/trogdor/workload/TimeIntervalTransactionsGeneratorTest.java	21
trogdor/src/test/java/org/apache/kafka/trogdor/workload/TopicsSpecTest.java	59
trogdor/src/test/resources/log4j2.yaml	20