Path	Lines of Code
clients/src/test/java/org/apache/kafka/clients/ApiVersionsTest.java	18
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java	89
clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java	289
clients/src/test/java/org/apache/kafka/clients/CommonClientConfigsTest.java	59
clients/src/test/java/org/apache/kafka/clients/FetchSessionHandlerTest.java	317
clients/src/test/java/org/apache/kafka/clients/InFlightRequestsTest.java	85
clients/src/test/java/org/apache/kafka/clients/MetadataCacheTest.java	53
clients/src/test/java/org/apache/kafka/clients/MetadataTest.java	652
clients/src/test/java/org/apache/kafka/clients/MockClient.java	568
clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java	742
clients/src/test/java/org/apache/kafka/clients/NodeApiVersionsTest.java	124
clients/src/test/java/org/apache/kafka/clients/admin/AdminClientTestUtils.java	11
clients/src/test/java/org/apache/kafka/clients/admin/AdminClientUnitTestEnv.java	85
clients/src/test/java/org/apache/kafka/clients/admin/ConfigTest.java	66
clients/src/test/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResultTest.java	84
clients/src/test/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResultTest.java	88
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java	3753
clients/src/test/java/org/apache/kafka/clients/admin/MemberDescriptionTest.java	67
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java	770
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/internals/AdminMetadataManagerTest.java	70
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerConfigTest.java	99
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerGroupMetadataTest.java	55
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerRecordTest.java	41
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerRecordsTest.java	33
clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java	59
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java	1846
clients/src/test/java/org/apache/kafka/clients/consumer/MockConsumerTest.java	107
clients/src/test/java/org/apache/kafka/clients/consumer/OffsetAndMetadataTest.java	35
clients/src/test/java/org/apache/kafka/clients/consumer/RangeAssignorTest.java	253
clients/src/test/java/org/apache/kafka/clients/consumer/RoundRobinAssignorTest.java	251
clients/src/test/java/org/apache/kafka/clients/consumer/StickyAssignorTest.java	190
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java	1084
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignorTest.java	60
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java	574
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java	2457
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptorsTest.java	124
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerMetadataTest.java	128
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClientTest.java	336
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java	146
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java	3435
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatTest.java	84
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/OffsetForLeaderEpochClientTest.java	123
clients/src/test/java/org/apache/kafka/clients/consumer/internals/PartitionAssignorAdapterTest.java	122
clients/src/test/java/org/apache/kafka/clients/consumer/internals/RequestFutureTest.java	175
clients/src/test/java/org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java	590
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ThrowOnAssignmentAssignor.java	23
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java	1032
clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java	673
clients/src/test/java/org/apache/kafka/clients/producer/ProducerConfigTest.java	64
clients/src/test/java/org/apache/kafka/clients/producer/ProducerRecordTest.java	45
clients/src/test/java/org/apache/kafka/clients/producer/RecordMetadataTest.java	56
clients/src/test/java/org/apache/kafka/clients/producer/RecordSendTest.java	62
clients/src/test/java/org/apache/kafka/clients/producer/RoundRobinPartitionerTest.java	91
clients/src/test/java/org/apache/kafka/clients/producer/UniformStickyPartitionerTest.java	149
clients/src/test/java/org/apache/kafka/clients/producer/internals/BufferPoolTest.java	322
clients/src/test/java/org/apache/kafka/clients/producer/internals/DefaultPartitionerTest.java	30
clients/src/test/java/org/apache/kafka/clients/producer/internals/FutureRecordMetadataTest.java	51
clients/src/test/java/org/apache/kafka/clients/producer/internals/ProducerBatchTest.java	216
clients/src/test/java/org/apache/kafka/clients/producer/internals/ProducerInterceptorsTest.java	139
clients/src/test/java/org/apache/kafka/clients/producer/internals/ProducerMetadataTest.java	221
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java	869
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java	2013
clients/src/test/java/org/apache/kafka/clients/producer/internals/StickyPartitionCacheTest.java	74
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java	2642
clients/src/test/java/org/apache/kafka/common/ClusterTest.java	66
clients/src/test/java/org/apache/kafka/common/KafkaFutureTest.java	163
clients/src/test/java/org/apache/kafka/common/PartitionInfoTest.java	20
clients/src/test/java/org/apache/kafka/common/TopicPartitionTest.java	29
clients/src/test/java/org/apache/kafka/common/acl/AclBindingTest.java	108
clients/src/test/java/org/apache/kafka/common/acl/AclOperationTest.java	65
clients/src/test/java/org/apache/kafka/common/acl/AclPermissionTypeTest.java	56
clients/src/test/java/org/apache/kafka/common/acl/ResourcePatternFilterTest.java	133
clients/src/test/java/org/apache/kafka/common/acl/ResourcePatternTest.java	23
clients/src/test/java/org/apache/kafka/common/cache/LRUCacheTest.java	58
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java	482
clients/src/test/java/org/apache/kafka/common/config/ConfigDefTest.java	588
clients/src/test/java/org/apache/kafka/common/config/ConfigResourceTest.java	22
clients/src/test/java/org/apache/kafka/common/config/ConfigTransformerTest.java	112
clients/src/test/java/org/apache/kafka/common/config/SaslConfigsTest.java	94
clients/src/test/java/org/apache/kafka/common/config/provider/DirectoryConfigProviderTest.java	114
clients/src/test/java/org/apache/kafka/common/config/provider/FileConfigProviderTest.java	66
clients/src/test/java/org/apache/kafka/common/config/provider/MockFileConfigProvider.java	40
clients/src/test/java/org/apache/kafka/common/config/provider/MockVaultConfigProvider.java	23
clients/src/test/java/org/apache/kafka/common/feature/FeaturesTest.java	127
clients/src/test/java/org/apache/kafka/common/feature/FinalizedVersionRangeTest.java	46
clients/src/test/java/org/apache/kafka/common/feature/SupportedVersionRangeTest.java	95
clients/src/test/java/org/apache/kafka/common/header/internals/RecordHeadersTest.java	148
clients/src/test/java/org/apache/kafka/common/internals/PartitionStatesTest.java	164
clients/src/test/java/org/apache/kafka/common/internals/TopicTest.java	67
clients/src/test/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPoolTest.java	118
clients/src/test/java/org/apache/kafka/common/message/ApiMessageTypeTest.java	66
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java	921
clients/src/test/java/org/apache/kafka/common/message/RecordsSerdeTest.java	92
clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java	282
clients/src/test/java/org/apache/kafka/common/metrics/FakeMetricsReporter.java	15
clients/src/test/java/org/apache/kafka/common/metrics/JmxReporterTest.java	147
clients/src/test/java/org/apache/kafka/common/metrics/KafkaMbeanTest.java	129
clients/src/test/java/org/apache/kafka/common/metrics/KafkaMetricsContextTest.java	56
clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java	758
clients/src/test/java/org/apache/kafka/common/metrics/SampleMetrics.java	7
clients/src/test/java/org/apache/kafka/common/metrics/SensorTest.java	255
clients/src/test/java/org/apache/kafka/common/metrics/TokenBucketTest.java	49
clients/src/test/java/org/apache/kafka/common/metrics/internals/IntGaugeSuiteTest.java	72
clients/src/test/java/org/apache/kafka/common/metrics/stats/FrequenciesTest.java	116
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/network/CertStores.java	60
clients/src/test/java/org/apache/kafka/common/network/ChannelBuildersTest.java	100
clients/src/test/java/org/apache/kafka/common/network/EchoServer.java	105
clients/src/test/java/org/apache/kafka/common/network/KafkaChannelTest.java	78
clients/src/test/java/org/apache/kafka/common/network/NetworkReceiveTest.java	43
clients/src/test/java/org/apache/kafka/common/network/NetworkTestUtils.java	88
clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java	283
clients/src/test/java/org/apache/kafka/common/network/PlaintextSender.java	22
clients/src/test/java/org/apache/kafka/common/network/SaslChannelBuilderTest.java	183
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java	923
clients/src/test/java/org/apache/kafka/common/network/SslSelectorTest.java	316
clients/src/test/java/org/apache/kafka/common/network/SslSender.java	55
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java	996
clients/src/test/java/org/apache/kafka/common/network/SslTransportTls12Tls13Test.java	111
clients/src/test/java/org/apache/kafka/common/network/SslVersionsTransportLayerTest.java	115
clients/src/test/java/org/apache/kafka/common/protocol/ApiKeysTest.java	34
clients/src/test/java/org/apache/kafka/common/protocol/ErrorsTest.java	60
clients/src/test/java/org/apache/kafka/common/protocol/MessageTestUtil.java	15
clients/src/test/java/org/apache/kafka/common/protocol/MessageUtilTest.java	56
clients/src/test/java/org/apache/kafka/common/protocol/ProtoUtilsTest.java	25
clients/src/test/java/org/apache/kafka/common/protocol/RecordsWritableTest.java	38
clients/src/test/java/org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java	380
clients/src/test/java/org/apache/kafka/common/protocol/types/RawTaggedFieldWriterTest.java	74
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	186
clients/src/test/java/org/apache/kafka/common/record/BufferSupplierTest.java	21
clients/src/test/java/org/apache/kafka/common/record/ByteBufferLogInputStreamTest.java	83
clients/src/test/java/org/apache/kafka/common/record/CompressionRatioEstimatorTest.java	29
clients/src/test/java/org/apache/kafka/common/record/CompressionTypeTest.java	30
clients/src/test/java/org/apache/kafka/common/record/ControlRecordTypeTest.java	25
clients/src/test/java/org/apache/kafka/common/record/DefaultRecordBatchTest.java	350
clients/src/test/java/org/apache/kafka/common/record/DefaultRecordTest.java	387
clients/src/test/java/org/apache/kafka/common/record/EndTransactionMarkerTest.java	45
clients/src/test/java/org/apache/kafka/common/record/FileLogInputStreamTest.java	221
clients/src/test/java/org/apache/kafka/common/record/FileRecordsTest.java	519
clients/src/test/java/org/apache/kafka/common/record/KafkaLZ4Test.java	260
clients/src/test/java/org/apache/kafka/common/record/LazyDownConversionRecordsTest.java	161
clients/src/test/java/org/apache/kafka/common/record/LegacyRecordTest.java	100
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsBuilderTest.java	604
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java	745
clients/src/test/java/org/apache/kafka/common/record/MultiRecordsSendTest.java	49
clients/src/test/java/org/apache/kafka/common/record/SimpleLegacyRecordTest.java	57
clients/src/test/java/org/apache/kafka/common/replica/ReplicaSelectorTest.java	56
clients/src/test/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequestTest.java	32
clients/src/test/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponseTest.java	63
clients/src/test/java/org/apache/kafka/common/requests/AlterReplicaLogDirsRequestTest.java	66
clients/src/test/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponseTest.java	35
clients/src/test/java/org/apache/kafka/common/requests/ApiVersionsResponseTest.java	107
clients/src/test/java/org/apache/kafka/common/requests/ByteBufferChannel.java	46
clients/src/test/java/org/apache/kafka/common/requests/ControlledShutdownRequestTest.java	29
clients/src/test/java/org/apache/kafka/common/requests/CreateAclsRequestTest.java	64
clients/src/test/java/org/apache/kafka/common/requests/DeleteAclsRequestTest.java	78
clients/src/test/java/org/apache/kafka/common/requests/DeleteAclsResponseTest.java	88
clients/src/test/java/org/apache/kafka/common/requests/DeleteGroupsResponseTest.java	52
clients/src/test/java/org/apache/kafka/common/requests/DescribeAclsRequestTest.java	79
clients/src/test/java/org/apache/kafka/common/requests/DescribeAclsResponseTest.java	119
clients/src/test/java/org/apache/kafka/common/requests/EndTxnRequestTest.java	29
clients/src/test/java/org/apache/kafka/common/requests/EndTxnResponseTest.java	24
clients/src/test/java/org/apache/kafka/common/requests/EpochEndOffsetTest.java	39
clients/src/test/java/org/apache/kafka/common/requests/HeartbeatRequestTest.java	15
clients/src/test/java/org/apache/kafka/common/requests/JoinGroupRequestTest.java	69
clients/src/test/java/org/apache/kafka/common/requests/LeaderAndIsrRequestTest.java	135
clients/src/test/java/org/apache/kafka/common/requests/LeaderAndIsrResponseTest.java	88
clients/src/test/java/org/apache/kafka/common/requests/LeaveGroupRequestTest.java	93
clients/src/test/java/org/apache/kafka/common/requests/LeaveGroupResponseTest.java	121
clients/src/test/java/org/apache/kafka/common/requests/MetadataRequestTest.java	43
clients/src/test/java/org/apache/kafka/common/requests/OffsetCommitRequestTest.java	110
clients/src/test/java/org/apache/kafka/common/requests/OffsetCommitResponseTest.java	68
clients/src/test/java/org/apache/kafka/common/requests/OffsetFetchRequestTest.java	104
clients/src/test/java/org/apache/kafka/common/requests/OffsetFetchResponseTest.java	174
clients/src/test/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequestTest.java	36
clients/src/test/java/org/apache/kafka/common/requests/ProduceRequestTest.java	193
clients/src/test/java/org/apache/kafka/common/requests/ProduceResponseTest.java	84
clients/src/test/java/org/apache/kafka/common/requests/RequestContextTest.java	60
clients/src/test/java/org/apache/kafka/common/requests/RequestHeaderTest.java	60
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java	2101
clients/src/test/java/org/apache/kafka/common/requests/StopReplicaRequestTest.java	195
clients/src/test/java/org/apache/kafka/common/requests/StopReplicaResponseTest.java	71
clients/src/test/java/org/apache/kafka/common/requests/SyncGroupRequestTest.java	15
clients/src/test/java/org/apache/kafka/common/requests/TxnOffsetCommitRequestTest.java	124
clients/src/test/java/org/apache/kafka/common/requests/TxnOffsetCommitResponseTest.java	42
clients/src/test/java/org/apache/kafka/common/requests/UpdateMetadataRequestTest.java	163
clients/src/test/java/org/apache/kafka/common/requests/WriteTxnMarkersRequestTest.java	53
clients/src/test/java/org/apache/kafka/common/requests/WriteTxnMarkersResponseTest.java	34
clients/src/test/java/org/apache/kafka/common/resource/ResourceFilterTest.java	54
clients/src/test/java/org/apache/kafka/common/resource/ResourceTypeTest.java	59
clients/src/test/java/org/apache/kafka/common/security/JaasContextTest.java	241
clients/src/test/java/org/apache/kafka/common/security/SaslExtensionsTest.java	28
clients/src/test/java/org/apache/kafka/common/security/TestSecurityConfig.java	27
clients/src/test/java/org/apache/kafka/common/security/auth/DefaultKafkaPrincipalBuilderTest.java	157
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	110
clients/src/test/java/org/apache/kafka/common/security/authenticator/LoginManagerTest.java	93
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorFailureDelayTest.java	178
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java	1735
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticatorTest.java	121
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	99
clients/src/test/java/org/apache/kafka/common/security/kerberos/KerberosRuleTest.java	25
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerExtensionsValidatorCallbackTest.java	55
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModuleTest.java	307
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerSaslClienCallbackHandlerTest.java	74
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/OAuthBearerValidatorCallbackTest.java	52
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerClientInitialResponseTest.java	84
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	170
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	489
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerScopeUtilsTest.java	31
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredJwsTest.java	124
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredLoginCallbackHandlerTest.java	128
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredValidatorCallbackHandlerTest.java	148
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerValidationUtilsTest.java	213
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	65
clients/src/test/java/org/apache/kafka/common/security/scram/internals/ScramFormatterTest.java	56
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	47
clients/src/test/java/org/apache/kafka/common/security/ssl/SslFactoryTest.java	388
clients/src/test/java/org/apache/kafka/common/security/ssl/SslPrincipalMapperTest.java	89
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestKeyManagerFactory.java	78
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	48
clients/src/test/java/org/apache/kafka/common/serialization/SerializationTest.java	142
clients/src/test/java/org/apache/kafka/common/utils/AbstractIteratorTest.java	45
clients/src/test/java/org/apache/kafka/common/utils/AppInfoParserTest.java	57
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	260
clients/src/test/java/org/apache/kafka/common/utils/BytesTest.java	52
clients/src/test/java/org/apache/kafka/common/utils/ChecksumsTest.java	58
clients/src/test/java/org/apache/kafka/common/utils/CircularIteratorTest.java	38
clients/src/test/java/org/apache/kafka/common/utils/CollectionUtilsTest.java	39
clients/src/test/java/org/apache/kafka/common/utils/Crc32CTest.java	26
clients/src/test/java/org/apache/kafka/common/utils/Crc32Test.java	26
clients/src/test/java/org/apache/kafka/common/utils/ExitTest.java	65
clients/src/test/java/org/apache/kafka/common/utils/ExponentialBackoffTest.java	27
clients/src/test/java/org/apache/kafka/common/utils/FixedOrderMapTest.java	50
clients/src/test/java/org/apache/kafka/common/utils/FlattenedIteratorTest.java	72
clients/src/test/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollectionTest.java	487
clients/src/test/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiCollectionTest.java	142
clients/src/test/java/org/apache/kafka/common/utils/JavaTest.java	59
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	82
clients/src/test/java/org/apache/kafka/common/utils/MockTime.java	81
clients/src/test/java/org/apache/kafka/common/utils/MockTimeTest.java	30
clients/src/test/java/org/apache/kafka/common/utils/SanitizerTest.java	55
clients/src/test/java/org/apache/kafka/common/utils/SecurityUtilsTest.java	69
clients/src/test/java/org/apache/kafka/common/utils/Serializer.java	30
clients/src/test/java/org/apache/kafka/common/utils/ShellTest.java	49
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	83
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java	635
clients/src/test/java/org/apache/kafka/test/DelayedReceive.java	16
clients/src/test/java/org/apache/kafka/test/IntegrationTest.java	3
clients/src/test/java/org/apache/kafka/test/MetricsBench.java	38
clients/src/test/java/org/apache/kafka/test/Microbenchmarks.java	158
clients/src/test/java/org/apache/kafka/test/MockClusterResourceListener.java	16
clients/src/test/java/org/apache/kafka/test/MockConsumerInterceptor.java	72
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	73
clients/src/test/java/org/apache/kafka/test/MockSelector.java	158
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	321
clients/src/test/java/org/apache/kafka/test/TestUtils.java	409
clients/src/test/java/org/apache/kafka/test/ValuelessCallable.java	4
connect/api/src/test/java/org/apache/kafka/connect/connector/ConnectorReconfigurationTest.java	57
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	243
connect/api/src/test/java/org/apache/kafka/connect/data/DateTest.java	49
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	302
connect/api/src/test/java/org/apache/kafka/connect/data/SchemaProjectorTest.java	418
connect/api/src/test/java/org/apache/kafka/connect/data/StructTest.java	267
connect/api/src/test/java/org/apache/kafka/connect/data/TimeTest.java	50
connect/api/src/test/java/org/apache/kafka/connect/data/TimestampTest.java	45
connect/api/src/test/java/org/apache/kafka/connect/data/ValuesTest.java	692
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	457
connect/api/src/test/java/org/apache/kafka/connect/sink/SinkConnectorTest.java	102
connect/api/src/test/java/org/apache/kafka/connect/sink/SinkRecordTest.java	98
connect/api/src/test/java/org/apache/kafka/connect/source/SourceConnectorTest.java	107
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	63
connect/api/src/test/java/org/apache/kafka/connect/storage/StringConverterTest.java	65
connect/api/src/test/java/org/apache/kafka/connect/util/ConnectorUtilsTest.java	38
connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilterTest.java	175
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkConnectorTest.java	68
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkTaskTest.java	87
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSourceConnectorTest.java	94
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSourceTaskTest.java	136
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	744
connect/mirror-client/src/test/java/org/apache/kafka/connect/mirror/MirrorClientTest.java	127
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/CheckpointTest.java	19
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/HeartbeatTest.java	17
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnectorTest.java	36
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointTaskTest.java	80
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorConfigTest.java	88
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java	312
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorHeartBeatConnectorTest.java	24
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorMakerConfigTest.java	200
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java	157
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceTaskTest.java	73
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncStoreTest.java	33
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/OffsetSyncTest.java	18
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/TestUtils.java	16
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/ByteArrayConverterTest.java	60
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	69
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	338
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectIntegrationTestUtils.java	21
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectWorkerIntegrationTest.java	184
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorClientPolicyIntegrationTest.java	108
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorHandle.java	135
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorTopicsIntegrationTest.java	216
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ErrantRecordSinkConnector.java	36
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ErrorHandlingIntegrationTest.java	216
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ExampleConnectIntegrationTest.java	133
connect/runtime/src/test/java/org/apache/kafka/connect/integration/InternalTopicsIntegrationTest.java	220
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSinkConnector.java	119
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSourceConnector.java	130
connect/runtime/src/test/java/org/apache/kafka/connect/integration/RebalanceSourceConnectorsIntegrationTest.java	204
connect/runtime/src/test/java/org/apache/kafka/connect/integration/RestExtensionIntegrationTest.java	153
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	109
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SourceConnectorsIntegrationTest.java	162
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	83
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	103
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TaskHandle.java	127
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.java	202
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java	557
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectMetricsTest.java	134
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectorConfigTest.java	398
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java	493
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskWithTopicCreationTest.java	506
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/MockConnectMetrics.java	95
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/PredicatedTransformationTest.java	84
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SourceConnectorConfigTest.java	112
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitterTest.java	138
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/StateTrackerTest.java	69
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TestConverterWithHeaders.java	48
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TestSinkConnector.java	33
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TestSourceConnector.java	33
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TransformationConfigTest.java	148
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConfigTest.java	87
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConfigTransformerTest.java	112
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConnectorTest.java	435
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java	1384
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java	567
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java	873
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskWithTopicCreationTest.java	1068
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java	262
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java	1244
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTestUtils.java	149
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerWithTopicCreationTest.java	1184
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocolCompatibilityTest.java	211
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedConfigTest.java	254
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java	1811
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java	1158
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorIncrementalTest.java	447
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.java	462
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMemberTest.java	74
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/ErrorReporterTest.java	273
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTest.java	271
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporterTest.java	45
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/health/ConnectClusterStateImplTest.java	94
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoaderTest.java	94
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginDescTest.java	181
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginUtilsTest.java	437
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginsTest.java	379
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/SamplingTestPlugin.java	67
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/TestPlugins.java	167
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignatureTest.java	112
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestServerTest.java	387
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/resources/ConnectorPluginsResourceTest.java	465
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResourceTest.java	721
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResourceTest.java	166
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/RootResourceTest.java	33
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/util/SSLUtilsTest.java	162
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	624
connect/runtime/src/test/java/org/apache/kafka/connect/storage/FileOffsetBackingStoreTest.java	90
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaConfigBackingStoreTest.java	741
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java	328
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreFormatTest.java	238
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreTest.java	346
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	179
connect/runtime/src/test/java/org/apache/kafka/connect/util/ByteArrayProducerRecordEquals.java	30
connect/runtime/src/test/java/org/apache/kafka/connect/util/ConnectUtilsTest.java	74
connect/runtime/src/test/java/org/apache/kafka/connect/util/ConvertingFutureCallbackTest.java	203
connect/runtime/src/test/java/org/apache/kafka/connect/util/KafkaBasedLogTest.java	444
connect/runtime/src/test/java/org/apache/kafka/connect/util/LoggingContextTest.java	155
connect/runtime/src/test/java/org/apache/kafka/connect/util/ShutdownableThreadTest.java	44
connect/runtime/src/test/java/org/apache/kafka/connect/util/TableTest.java	24
connect/runtime/src/test/java/org/apache/kafka/connect/util/TestBackgroundThreadExceptionHandler.java	13
connect/runtime/src/test/java/org/apache/kafka/connect/util/TestFuture.java	105
connect/runtime/src/test/java/org/apache/kafka/connect/util/ThreadedTest.java	16
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicAdminTest.java	501
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicCreationTest.java	506
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java	445
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectClusterAssertions.java	294
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java	337
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	58
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	25
connect/runtime/src/test/resources/test-plugins/sampling-config-provider/test/plugins/SamplingConfigProvider.java	66
connect/runtime/src/test/resources/test-plugins/sampling-configurable/test/plugins/SamplingConfigurable.java	47
connect/runtime/src/test/resources/test-plugins/sampling-converter/test/plugins/SamplingConverter.java	45
connect/runtime/src/test/resources/test-plugins/sampling-header-converter/test/plugins/SamplingHeaderConverter.java	56
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/transforms/src/test/java/org/apache/kafka/connect/transforms/CastTest.java	414
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ExtractFieldTest.java	77
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/FlattenTest.java	242
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/HoistFieldTest.java	33
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertFieldTest.java	140
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/MaskFieldTest.java	211
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/RegexRouterTest.java	42
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ReplaceFieldTest.java	89
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/SetSchemaMetadataTest.java	108
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/TimestampConverterTest.java	412
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/TimestampRouterTest.java	25
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ValueToKeyTest.java	71
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	18
core/src/test/scala/integration/kafka/admin/BrokerApiVersionsCommandTest.scala	40
core/src/test/scala/integration/kafka/admin/ReassignPartitionsIntegrationTest.scala	475
core/src/test/scala/integration/kafka/api/AbstractConsumerTest.scala	293
core/src/test/scala/integration/kafka/api/AdminClientWithPoliciesIntegrationTest.scala	145
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala	1548
core/src/test/scala/integration/kafka/api/BaseAdminIntegrationTest.scala	177
core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala	42
core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala	366
core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala	299
core/src/test/scala/integration/kafka/api/ClientIdQuotaTest.scala	49
core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala	391
core/src/test/scala/integration/kafka/api/ConsumerTopicCreationTest.scala	60
core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala	355
core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala	84
core/src/test/scala/integration/kafka/api/DescribeAuthorizedOperationsTest.scala	140
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala	448
core/src/test/scala/integration/kafka/api/EndToEndClusterIdTest.scala	145
core/src/test/scala/integration/kafka/api/FixedPortTestUtils.scala	26
core/src/test/scala/integration/kafka/api/GroupAuthorizerIntegrationTest.scala	102
core/src/test/scala/integration/kafka/api/GroupCoordinatorIntegrationTest.scala	41
core/src/test/scala/integration/kafka/api/GroupEndToEndAuthorizationTest.scala	27
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala	115
core/src/test/scala/integration/kafka/api/LogAppendTimeTest.scala	47
core/src/test/scala/integration/kafka/api/MetricsTest.scala	237
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala	1848
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala	1348
core/src/test/scala/integration/kafka/api/PlaintextEndToEndAuthorizationTest.scala	60
core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala	140
core/src/test/scala/integration/kafka/api/ProducerCompressionTest.scala	78
core/src/test/scala/integration/kafka/api/ProducerFailureHandlingTest.scala	186
core/src/test/scala/integration/kafka/api/RackAwareAutoTopicCreationTest.scala	39
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala	207
core/src/test/scala/integration/kafka/api/SaslEndToEndAuthorizationTest.scala	44
core/src/test/scala/integration/kafka/api/SaslGssapiSslEndToEndAuthorizationTest.scala	16
core/src/test/scala/integration/kafka/api/SaslMultiMechanismConsumerTest.scala	58
core/src/test/scala/integration/kafka/api/SaslOAuthBearerSslEndToEndAuthorizationTest.scala	9
core/src/test/scala/integration/kafka/api/SaslPlainPlaintextConsumerTest.scala	35
core/src/test/scala/integration/kafka/api/SaslPlainSslEndToEndAuthorizationTest.scala	101
core/src/test/scala/integration/kafka/api/SaslPlaintextConsumerTest.scala	17
core/src/test/scala/integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala	26
core/src/test/scala/integration/kafka/api/SaslSetup.scala	160
core/src/test/scala/integration/kafka/api/SaslSslAdminIntegrationTest.scala	427
core/src/test/scala/integration/kafka/api/SaslSslConsumerTest.scala	21
core/src/test/scala/integration/kafka/api/SslAdminIntegrationTest.scala	251
core/src/test/scala/integration/kafka/api/SslConsumerTest.scala	7
core/src/test/scala/integration/kafka/api/SslEndToEndAuthorizationTest.scala	50
core/src/test/scala/integration/kafka/api/SslProducerSendTest.scala	7
core/src/test/scala/integration/kafka/api/TransactionsBounceTest.scala	149
core/src/test/scala/integration/kafka/api/TransactionsExpirationTest.scala	80
core/src/test/scala/integration/kafka/api/TransactionsTest.scala	611
core/src/test/scala/integration/kafka/api/UserClientIdQuotaTest.scala	61
core/src/test/scala/integration/kafka/api/UserQuotaTest.scala	60
core/src/test/scala/integration/kafka/network/DynamicConnectionQuotaTest.scala	251
core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala	122
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala	1501
core/src/test/scala/integration/kafka/server/GssapiAuthenticationTest.scala	131
core/src/test/scala/integration/kafka/server/MultipleListenersWithAdditionalJaasContextTest.scala	21
core/src/test/scala/integration/kafka/server/MultipleListenersWithDefaultJaasContextTest.scala	10
core/src/test/scala/integration/kafka/server/MultipleListenersWithSameSecurityProtocolBaseTest.scala	134
core/src/test/scala/integration/kafka/server/ScramServerStartupTest.scala	30
core/src/test/scala/integration/kafka/tools/MirrorMakerIntegrationTest.scala	94
core/src/test/scala/kafka/common/InterBrokerSendThreadTest.scala	150
core/src/test/scala/kafka/metrics/LinuxIoMetricsCollectorTest.scala	52
core/src/test/scala/kafka/security/auth/ResourceTest.scala	41
core/src/test/scala/kafka/security/minikdc/MiniKdc.scala	312
core/src/test/scala/kafka/security/minikdc/MiniKdcTest.scala	26
core/src/test/scala/kafka/server/BrokerMetadataCheckpointTest.scala	10
core/src/test/scala/kafka/server/BrokerToControllerRequestThreadTest.scala	137
core/src/test/scala/kafka/tools/CustomDeserializerTest.scala	39
core/src/test/scala/kafka/tools/LogCompactionTester.scala	275
core/src/test/scala/kafka/tools/ReplicaVerificationToolTest.scala	34
core/src/test/scala/kafka/utils/ExitTest.scala	88
core/src/test/scala/kafka/utils/LoggingTest.scala	38
core/src/test/scala/kafka/utils/ToolsUtilsTest.scala	23
core/src/test/scala/kafka/zk/ExtendedAclStoreTest.scala	40
core/src/test/scala/kafka/zk/FeatureZNodeTest.scala	91
core/src/test/scala/kafka/zk/LiteralAclStoreTest.scala	45
core/src/test/scala/other/kafka/ReplicationQuotasTestRig.scala	261
core/src/test/scala/other/kafka/StressTestLog.scala	111
core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala	188
core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala	219
core/src/test/scala/other/kafka/TestTruncate.scala	19
core/src/test/scala/unit/kafka/KafkaConfigTest.scala	230
core/src/test/scala/unit/kafka/admin/AclCommandTest.scala	271
core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala	149
core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala	187
core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala	1274
core/src/test/scala/unit/kafka/admin/ConsumerGroupCommandTest.scala	158
core/src/test/scala/unit/kafka/admin/DelegationTokenCommandTest.scala	100
core/src/test/scala/unit/kafka/admin/DeleteConsumerGroupsTest.scala	172
core/src/test/scala/unit/kafka/admin/DeleteOffsetsConsumerGroupCommandIntegrationTest.scala	153
core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala	336
core/src/test/scala/unit/kafka/admin/DescribeConsumerGroupTest.scala	529
core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala	265
core/src/test/scala/unit/kafka/admin/ListConsumerGroupTest.scala	96
core/src/test/scala/unit/kafka/admin/PreferredReplicaLeaderElectionCommandTest.scala	304
core/src/test/scala/unit/kafka/admin/RackAwareTest.scala	55
core/src/test/scala/unit/kafka/admin/ReassignPartitionsCommandArgsTest.scala	262
core/src/test/scala/unit/kafka/admin/ReassignPartitionsUnitTest.scala	591
core/src/test/scala/unit/kafka/admin/ReplicationQuotaUtils.scala	37
core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala	422
core/src/test/scala/unit/kafka/admin/TopicCommandTest.scala	36
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala	660
core/src/test/scala/unit/kafka/admin/TopicCommandWithZKClientTest.scala	454
core/src/test/scala/unit/kafka/admin/UserScramCredentialsCommandTest.scala	100
core/src/test/scala/unit/kafka/api/ApiUtilsTest.scala	50
core/src/test/scala/unit/kafka/api/ApiVersionTest.scala	106
core/src/test/scala/unit/kafka/cluster/AbstractPartitionTest.scala	68
core/src/test/scala/unit/kafka/cluster/AssignmentStateTest.scala	96
core/src/test/scala/unit/kafka/cluster/BrokerEndPointTest.scala	231
core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala	262
core/src/test/scala/unit/kafka/cluster/PartitionTest.scala	1260
core/src/test/scala/unit/kafka/cluster/ReplicaTest.scala	92
core/src/test/scala/unit/kafka/common/ZkNodeChangeNotificationListenerTest.scala	67
core/src/test/scala/unit/kafka/controller/ControllerChannelManagerTest.scala	723
core/src/test/scala/unit/kafka/controller/ControllerContextTest.scala	146
core/src/test/scala/unit/kafka/controller/ControllerEventManagerTest.scala	166
core/src/test/scala/unit/kafka/controller/ControllerFailoverTest.scala	66
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala	689
core/src/test/scala/unit/kafka/controller/MockPartitionStateMachine.scala	96
core/src/test/scala/unit/kafka/controller/MockReplicaStateMachine.scala	27
core/src/test/scala/unit/kafka/controller/PartitionLeaderElectionAlgorithmsTest.scala	155
core/src/test/scala/unit/kafka/controller/PartitionStateMachineTest.scala	425
core/src/test/scala/unit/kafka/controller/ReplicaStateMachineTest.scala	342
core/src/test/scala/unit/kafka/controller/TopicDeletionManagerTest.scala	196
core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala	170
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala	336
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala	3016
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala	1846
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataTest.scala	484
core/src/test/scala/unit/kafka/coordinator/group/MemberMetadataTest.scala	64
core/src/test/scala/unit/kafka/coordinator/transaction/ProducerIdManagerTest.scala	55
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorConcurrencyTest.scala	489
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala	895
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionLogTest.scala	96
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala	392
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandlerTest.scala	200
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMetadataTest.scala	406
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionStateManagerTest.scala	592
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala	86
core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala	96
core/src/test/scala/unit/kafka/integration/MinIsrConfigTest.scala	14
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala	230
core/src/test/scala/unit/kafka/log/AbstractLogCleanerIntegrationTest.scala	127
core/src/test/scala/unit/kafka/log/BrokerCompressionTest.scala	57
core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala	146
core/src/test/scala/unit/kafka/log/LogCleanerLagIntegrationTest.scala	85
core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala	492
core/src/test/scala/unit/kafka/log/LogCleanerParameterizedIntegrationTest.scala	231
core/src/test/scala/unit/kafka/log/LogCleanerTest.scala	1245
core/src/test/scala/unit/kafka/log/LogConcurrencyTest.scala	136
core/src/test/scala/unit/kafka/log/LogConfigTest.scala	134
core/src/test/scala/unit/kafka/log/LogManagerTest.scala	439
core/src/test/scala/unit/kafka/log/LogSegmentTest.scala	413
core/src/test/scala/unit/kafka/log/LogTest.scala	3437
core/src/test/scala/unit/kafka/log/LogUtils.scala	16
core/src/test/scala/unit/kafka/log/LogValidatorTest.scala	1355
core/src/test/scala/unit/kafka/log/OffsetIndexTest.scala	174
core/src/test/scala/unit/kafka/log/OffsetMapTest.scala	61
core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala	701
core/src/test/scala/unit/kafka/log/TimeIndexTest.scala	104
core/src/test/scala/unit/kafka/log/TransactionIndexTest.scala	123
core/src/test/scala/unit/kafka/metrics/KafkaTimerTest.scala	33
core/src/test/scala/unit/kafka/metrics/MetricsTest.scala	148
core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala	469
core/src/test/scala/unit/kafka/network/RequestChannelTest.scala	145
core/src/test/scala/unit/kafka/network/SocketServerTest.scala	1567
core/src/test/scala/unit/kafka/security/auth/OperationTest.scala	17
core/src/test/scala/unit/kafka/security/auth/PermissionTypeTest.scala	30
core/src/test/scala/unit/kafka/security/auth/ResourceTypeTest.scala	30
core/src/test/scala/unit/kafka/security/auth/SimpleAclAuthorizerTest.scala	528
core/src/test/scala/unit/kafka/security/auth/ZkAuthorizationTest.scala	231
core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerTest.scala	861
core/src/test/scala/unit/kafka/security/authorizer/AclEntryTest.scala	22
core/src/test/scala/unit/kafka/security/token/delegation/DelegationTokenManagerTest.scala	253
core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala	26
core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala	159
core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala	94
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala	754
core/src/test/scala/unit/kafka/server/AddPartitionsToTxnRequestServerTest.scala	40
core/src/test/scala/unit/kafka/server/AdminManagerTest.scala	54
core/src/test/scala/unit/kafka/server/AdvertiseBrokerTest.scala	64
core/src/test/scala/unit/kafka/server/AlterReplicaLogDirsRequestTest.scala	95
core/src/test/scala/unit/kafka/server/AlterUserScramCredentialsRequestTest.scala	357
core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala	41
core/src/test/scala/unit/kafka/server/BaseClientQuotaManagerTest.scala	62
core/src/test/scala/unit/kafka/server/BaseRequestTest.scala	108
core/src/test/scala/unit/kafka/server/BrokerEpochIntegrationTest.scala	217
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala	281
core/src/test/scala/unit/kafka/server/ClientQuotasRequestTest.scala	353
core/src/test/scala/unit/kafka/server/ClientRequestQuotaManagerTest.scala	49
core/src/test/scala/unit/kafka/server/ControllerMutationQuotaManagerTest.scala	158
core/src/test/scala/unit/kafka/server/ControllerMutationQuotaTest.scala	261
core/src/test/scala/unit/kafka/server/CreateTopicsRequestTest.scala	134
core/src/test/scala/unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala	109
core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala	317
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsOnPlainTextTest.scala	42
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsTest.scala	88
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsWithDisableTokenFeatureTest.scala	51
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestTest.scala	94
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestWithDeletionDisabledTest.scala	38
core/src/test/scala/unit/kafka/server/DescribeLogDirsRequestTest.scala	49
core/src/test/scala/unit/kafka/server/DescribeUserScramCredentialsRequestTest.scala	108
core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala	340
core/src/test/scala/unit/kafka/server/DynamicConfigChangeTest.scala	262
core/src/test/scala/unit/kafka/server/DynamicConfigTest.scala	27
core/src/test/scala/unit/kafka/server/EdgeCaseRequestTest.scala	132
core/src/test/scala/unit/kafka/server/FetchRequestDownConversionConfigTest.scala	109
core/src/test/scala/unit/kafka/server/FetchRequestMaxBytesTest.scala	90
core/src/test/scala/unit/kafka/server/FetchRequestTest.scala	522
core/src/test/scala/unit/kafka/server/FetchSessionTest.scala	481
core/src/test/scala/unit/kafka/server/FinalizedFeatureCacheTest.scala	76
core/src/test/scala/unit/kafka/server/FinalizedFeatureChangeListenerTest.scala	158
core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala	134
core/src/test/scala/unit/kafka/server/IsrExpirationTest.scala	157
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala	1900
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala	772
core/src/test/scala/unit/kafka/server/KafkaMetricReporterClusterIdTest.scala	77
core/src/test/scala/unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala	79
core/src/test/scala/unit/kafka/server/KafkaMetricsReporterTest.scala	59
core/src/test/scala/unit/kafka/server/KafkaServerTest.scala	76
core/src/test/scala/unit/kafka/server/LeaderElectionTest.scala	121
core/src/test/scala/unit/kafka/server/ListOffsetsRequestTest.scala	114
core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala	145
core/src/test/scala/unit/kafka/server/LogOffsetTest.scala	192
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala	157
core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala	388
core/src/test/scala/unit/kafka/server/MetadataRequestTest.scala	283
core/src/test/scala/unit/kafka/server/OffsetsForLeaderEpochRequestTest.scala	64
core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala	146
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala	639
core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala	53
core/src/test/scala/unit/kafka/server/ReplicaFetcherThreadTest.scala	571
core/src/test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala	215
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala	1736
core/src/test/scala/unit/kafka/server/ReplicationQuotaManagerTest.scala	67
core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala	146
core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala	577
core/src/test/scala/unit/kafka/server/SaslApiVersionsRequestTest.scala	74
core/src/test/scala/unit/kafka/server/ServerGenerateBrokerIdTest.scala	149
core/src/test/scala/unit/kafka/server/ServerGenerateClusterIdTest.scala	153
core/src/test/scala/unit/kafka/server/ServerMetricsTest.scala	27
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala	191
core/src/test/scala/unit/kafka/server/ServerStartupTest.scala	85
core/src/test/scala/unit/kafka/server/StopReplicaRequestTest.scala	53
core/src/test/scala/unit/kafka/server/SupportedFeaturesTest.scala	32
core/src/test/scala/unit/kafka/server/ThrottledChannelExpirationTest.scala	93
core/src/test/scala/unit/kafka/server/checkpoints/LeaderEpochCheckpointFileTest.scala	30
core/src/test/scala/unit/kafka/server/checkpoints/OffsetCheckpointFileTest.scala	78
core/src/test/scala/unit/kafka/server/epoch/EpochDrivenReplicationProtocolAcceptanceTest.scala	282
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala	317
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochIntegrationTest.scala	184
core/src/test/scala/unit/kafka/server/epoch/OffsetsForLeaderEpochTest.scala	67
core/src/test/scala/unit/kafka/server/epoch/util/ReplicaFetcherMockBlockingSend.scala	66
core/src/test/scala/unit/kafka/tools/ConsoleConsumerTest.scala	419
core/src/test/scala/unit/kafka/tools/ConsoleProducerTest.scala	94
core/src/test/scala/unit/kafka/tools/ConsumerPerformanceTest.scala	84
core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala	131
core/src/test/scala/unit/kafka/tools/MirrorMakerTest.scala	53
core/src/test/scala/unit/kafka/utils/CommandLineUtilsTest.scala	169
core/src/test/scala/unit/kafka/utils/CoreUtilsTest.scala	211
core/src/test/scala/unit/kafka/utils/JaasTestUtils.scala	232
core/src/test/scala/unit/kafka/utils/JsonTest.scala	88
core/src/test/scala/unit/kafka/utils/LogCaptureAppender.scala	39
core/src/test/scala/unit/kafka/utils/MockScheduler.scala	89
core/src/test/scala/unit/kafka/utils/MockTime.scala	10
core/src/test/scala/unit/kafka/utils/PasswordEncoderTest.scala	92
core/src/test/scala/unit/kafka/utils/PoolTest.scala	18
core/src/test/scala/unit/kafka/utils/QuotaUtilsTest.scala	91
core/src/test/scala/unit/kafka/utils/ReplicationUtilsTest.scala	62
core/src/test/scala/unit/kafka/utils/SchedulerTest.scala	121
core/src/test/scala/unit/kafka/utils/ShutdownableThreadTest.scala	30
core/src/test/scala/unit/kafka/utils/TestUtils.scala	1321
core/src/test/scala/unit/kafka/utils/ThrottlerTest.scala	32
core/src/test/scala/unit/kafka/utils/TopicFilterTest.scala	24
core/src/test/scala/unit/kafka/utils/json/JsonValueTest.scala	161
core/src/test/scala/unit/kafka/utils/timer/MockTimer.scala	42
core/src/test/scala/unit/kafka/utils/timer/TimerTaskListTest.scala	57
core/src/test/scala/unit/kafka/utils/timer/TimerTest.scala	69
core/src/test/scala/unit/kafka/zk/AdminZkClientTest.scala	265
core/src/test/scala/unit/kafka/zk/EmbeddedZookeeper.scala	31
core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala	967
core/src/test/scala/unit/kafka/zk/ReassignPartitionsZNodeTest.scala	32
core/src/test/scala/unit/kafka/zk/ZkFourLetterWords.scala	21
core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala	80
core/src/test/scala/unit/kafka/zookeeper/ZooKeeperClientTest.scala	580
generator/src/test/java/org/apache/kafka/message/CodeBufferTest.java	50
generator/src/test/java/org/apache/kafka/message/EntityTypeTest.java	65
generator/src/test/java/org/apache/kafka/message/IsNullConditionalTest.java	98
generator/src/test/java/org/apache/kafka/message/MessageDataGeneratorTest.java	220
generator/src/test/java/org/apache/kafka/message/MessageGeneratorTest.java	47
generator/src/test/java/org/apache/kafka/message/StructRegistryTest.java	124
generator/src/test/java/org/apache/kafka/message/VersionConditionalTest.java	211
generator/src/test/java/org/apache/kafka/message/VersionsTest.java	87
log4j-appender/src/test/java/org/apache/kafka/log4jappender/KafkaLog4jAppenderTest.java	177
log4j-appender/src/test/java/org/apache/kafka/log4jappender/MockKafkaLog4jAppender.java	34
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountDemoTest.java	87
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorTest.java	34
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerTest.java	35
streams/src/test/java/org/apache/kafka/common/metrics/SensorAccessor.java	11
streams/src/test/java/org/apache/kafka/streams/EqualityCheck.java	104
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java	852
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsWrapper.java	20
streams/src/test/java/org/apache/kafka/streams/KeyValueTest.java	40
streams/src/test/java/org/apache/kafka/streams/KeyValueTimestamp.java	38
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java	765
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java	855
streams/src/test/java/org/apache/kafka/streams/TopologyTest.java	1078
streams/src/test/java/org/apache/kafka/streams/TopologyTestDriverWrapper.java	30
streams/src/test/java/org/apache/kafka/streams/TopologyWrapper.java	14
streams/src/test/java/org/apache/kafka/streams/errors/AlwaysContinueProductionExceptionHandler.java	13
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java	178
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java	319
streams/src/test/java/org/apache/kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java	116
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java	797
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java	666
streams/src/test/java/org/apache/kafka/streams/integration/FineGrainedAutoResetIntegrationTest.java	248
streams/src/test/java/org/apache/kafka/streams/integration/ForeignKeyJoinSuite.java	23
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java	373
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableIntegrationTest.java	330
streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java	158
streams/src/test/java/org/apache/kafka/streams/integration/HighAvailabilityTaskAssignorIntegrationTest.java	248
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java	150
streams/src/test/java/org/apache/kafka/streams/integration/JoinStoreIntegrationTest.java	83
streams/src/test/java/org/apache/kafka/streams/integration/JoinWithIncompleteMetadataIntegrationTest.java	75
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationDedupIntegrationTest.java	202
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java	928
streams/src/test/java/org/apache/kafka/streams/integration/KStreamRepartitionIntegrationTest.java	614
streams/src/test/java/org/apache/kafka/streams/integration/KStreamTransformIntegrationTest.java	478
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java	214
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java	598
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializationIntegrationTest.java	157
streams/src/test/java/org/apache/kafka/streams/integration/KTableSourceTopicRestartIntegrationTest.java	193
streams/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java	288
streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java	766
streams/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java	146
streams/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.java	163
streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java	994
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java	367
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java	205
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationWithSslTest.java	45
streams/src/test/java/org/apache/kafka/streams/integration/ResetPartitionTimeIntegrationTest.java	155
streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java	375
streams/src/test/java/org/apache/kafka/streams/integration/RocksDBMetricsIntegrationTest.java	280
streams/src/test/java/org/apache/kafka/streams/integration/SmokeTestDriverIntegrationTest.java	100
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskCreationIntegrationTest.java	145
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java	304
streams/src/test/java/org/apache/kafka/streams/integration/StateRestorationIntegrationTest.java	84
streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java	299
streams/src/test/java/org/apache/kafka/streams/integration/StoreQuerySuite.java	21
streams/src/test/java/org/apache/kafka/streams/integration/StoreUpgradeIntegrationTest.java	864
streams/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java	351
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinIntegrationTest.java	78
streams/src/test/java/org/apache/kafka/streams/integration/StreamsUpgradeTestIntegrationTest.java	93
streams/src/test/java/org/apache/kafka/streams/integration/SuppressionDurabilityIntegrationTest.java	274
streams/src/test/java/org/apache/kafka/streams/integration/SuppressionIntegrationTest.java	437
streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java	478
streams/src/test/java/org/apache/kafka/streams/integration/TaskAssignorIntegrationTest.java	99
streams/src/test/java/org/apache/kafka/streams/integration/utils/CompositeStateListener.java	23
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java	219
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java	915
streams/src/test/java/org/apache/kafka/streams/integration/utils/KafkaEmbedded.java	136
streams/src/test/java/org/apache/kafka/streams/internals/ApiUtilsTest.java	72
streams/src/test/java/org/apache/kafka/streams/internals/metrics/ClientMetricsTest.java	103
streams/src/test/java/org/apache/kafka/streams/kstream/JoinWindowsTest.java	109
streams/src/test/java/org/apache/kafka/streams/kstream/MaterializedTest.java	63
streams/src/test/java/org/apache/kafka/streams/kstream/NamedTest.java	24
streams/src/test/java/org/apache/kafka/streams/kstream/PrintedTest.java	99
streams/src/test/java/org/apache/kafka/streams/kstream/RepartitionTopicNamingTest.java	550
streams/src/test/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializerTest.java	35
streams/src/test/java/org/apache/kafka/streams/kstream/SessionWindowedSerializerTest.java	35
streams/src/test/java/org/apache/kafka/streams/kstream/SessionWindowsTest.java	69
streams/src/test/java/org/apache/kafka/streams/kstream/SlidingWindowsTest.java	55
streams/src/test/java/org/apache/kafka/streams/kstream/SuppressedTest.java	100
streams/src/test/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializerTest.java	36
streams/src/test/java/org/apache/kafka/streams/kstream/TimeWindowedSerializerTest.java	35
streams/src/test/java/org/apache/kafka/streams/kstream/TimeWindowsTest.java	142
streams/src/test/java/org/apache/kafka/streams/kstream/UnlimitedWindowsTest.java	62
streams/src/test/java/org/apache/kafka/streams/kstream/WindowTest.java	57
streams/src/test/java/org/apache/kafka/streams/kstream/WindowedSerdesTest.java	129
streams/src/test/java/org/apache/kafka/streams/kstream/WindowsTest.java	35
streams/src/test/java/org/apache/kafka/streams/kstream/internals/AbstractStreamTest.java	102
streams/src/test/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImplTest.java	1041
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	296
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImplTest.java	663
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImplTest.java	324
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamBranchTest.java	58
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	59
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValuesTest.java	81
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransformTest.java	91
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransformValuesTest.java	89
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	144
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableLeftJoinTest.java	155
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java	2617
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java	873
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamLeftJoinTest.java	232
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinTest.java	308
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	52
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	50
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamRepartitionTest.java	124
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	546
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java	709
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformTest.java	128
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValuesTest.java	111
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregateTest.java	465
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableAggregateTest.java	247
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableFilterTest.java	336
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java	400
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableForeignKeyJoinScenarioTest.java	201
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoinTest.java	342
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinTest.java	395
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoinTest.java	317
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoinTest.java	52
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	215
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableReduceTest.java	55
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java	297
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableTransformValuesTest.java	440
streams/src/test/java/org/apache/kafka/streams/kstream/internals/MaterializedInternalTest.java	48
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	31
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionTupleForwarderTest.java	63
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowTest.java	68
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImplTest.java	266
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java	249
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImplTest.java	191
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImplTest.java	387
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressScenarioTest.java	705
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressTopologyTest.java	174
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowTest.java	78
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImplTest.java	257
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImplTest.java	272
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimestampedCacheFlushListenerTest.java	50
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimestampedTupleForwarderTest.java	63
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapterTest.java	114
streams/src/test/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindowTest.java	18
streams/src/test/java/org/apache/kafka/streams/kstream/internals/WindowedStreamPartitionerTest.java	51
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchemaTest.java	61
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolverJoinProcessorSupplierTest.java	190
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java	96
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java	60
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/GraphGraceSearchUtilTest.java	181
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphTest.java	419
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNodeTest.java	36
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNodeTest.java	48
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorMetricsTest.java	260
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorTest.java	345
streams/src/test/java/org/apache/kafka/streams/kstream/internals/suppress/SuppressSuite.java	28
streams/src/test/java/org/apache/kafka/streams/processor/DefaultPartitionGrouperTest.java	71
streams/src/test/java/org/apache/kafka/streams/processor/FailOnInvalidTimestampTest.java	15
streams/src/test/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestampTest.java	32
streams/src/test/java/org/apache/kafka/streams/processor/TimestampExtractorTest.java	25
streams/src/test/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestampTest.java	32
streams/src/test/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestampTest.java	33
streams/src/test/java/org/apache/kafka/streams/processor/WallclockTimestampExtractorTest.java	34
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.java	210
streams/src/test/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreatorTest.java	345
streams/src/test/java/org/apache/kafka/streams/processor/internals/ClientUtilsTest.java	91
streams/src/test/java/org/apache/kafka/streams/processor/internals/CopartitionedTopicsEnforcerTest.java	157
streams/src/test/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContextTest.java	38
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImplTest.java	184
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java	1060
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateTaskTest.java	196
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java	245
streams/src/test/java/org/apache/kafka/streams/processor/internals/HandlingSourceTopicDeletionIntegrationTest.java	81
streams/src/test/java/org/apache/kafka/streams/processor/internals/HighAvailabilityStreamsPartitionAssignorTest.java	261
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicConfigTest.java	76
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java	383
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java	918
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockChangelogReader.java	46
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockStreamsMetrics.java	10
streams/src/test/java/org/apache/kafka/streams/processor/internals/PartitionGroupTest.java	376
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java	628
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java	56
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java	161
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContextTest.java	68
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java	816
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyFactories.java	30
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java	810
streams/src/test/java/org/apache/kafka/streams/processor/internals/PunctuationQueueTest.java	102
streams/src/test/java/org/apache/kafka/streams/processor/internals/QuickUnionTest.java	61
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java	738
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordDeserializerTest.java	79
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordQueueTest.java	294
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionOptimizingTest.java	388
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfigTest.java	32
streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionWithMergeOptimizingTest.java	247
streams/src/test/java/org/apache/kafka/streams/processor/internals/SingleGroupPartitionGrouperStub.java	21
streams/src/test/java/org/apache/kafka/streams/processor/internals/SinkNodeTest.java	34
streams/src/test/java/org/apache/kafka/streams/processor/internals/SourceNodeTest.java	97
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java	457
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateConsumerTest.java	125
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java	451
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerStub.java	44
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java	258
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateRestoreCallbackAdapterTest.java	105
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java	825
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java	1797
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java	1990
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsMetadataStateTest.java	297
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java	1690
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsProducerTest.java	852
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListenerTest.java	48
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java	2266
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskSuite.java	19
streams/src/test/java/org/apache/kafka/streams/processor/internals/TimestampedKeyValueStoreMaterializerTest.java	95
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfoTest.java	136
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentTestUtils.java	347
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfigurationTest.java	16
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientStateTest.java	399
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/FallbackPriorTaskAssignorTest.java	48
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java	699
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacySubscriptionInfoSerde.java	216
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignorTest.java	596
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfoTest.java	306
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignorConvergenceTest.java	351
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovementTest.java	173
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetricsTest.java	356
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImplTest.java	1041
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetricsTest.java	294
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetricsTest.java	389
streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/LogCaptureAppender.java	90
streams/src/test/java/org/apache/kafka/streams/state/HostInfoTest.java	28
streams/src/test/java/org/apache/kafka/streams/state/KeyValueStoreTestDriver.java	181
streams/src/test/java/org/apache/kafka/streams/state/NoOpWindowStore.java	110
streams/src/test/java/org/apache/kafka/streams/state/StateSerdesTest.java	105
streams/src/test/java/org/apache/kafka/streams/state/StoresTest.java	229
streams/src/test/java/org/apache/kafka/streams/state/StreamsMetadataTest.java	38
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java	428
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStoreTest.java	420
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractSessionBytesStoreTest.java	447
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractWindowBytesStoreTest.java	1037
streams/src/test/java/org/apache/kafka/streams/state/internals/BlockBasedTableConfigWithAccessibleCacheTest.java	29
streams/src/test/java/org/apache/kafka/streams/state/internals/BufferValueTest.java	161
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java	452
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java	487
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingWindowStoreTest.java	788
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.java	128
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStoreTest.java	109
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueBytesStoreTest.java	143
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesStoreTest.java	87
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStoreTest.java	106
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStoreTest.java	305
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStoreTest.java	123
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStoreTest.java	370
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	97
streams/src/test/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProviderTest.java	157
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	36
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	56
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBufferTest.java	38
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryWindowStoreTest.java	119
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueIteratorFacadeTest.java	58
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentTest.java	89
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentsTest.java	288
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilderTest.java	107
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	193
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedSessionStoreIteratorTest.java	77
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedWindowStoreIteratorTest.java	179
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest.java	149
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java	337
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredSessionStoreTest.java	369
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStoreTest.java	386
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStoreTest.java	171
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreTest.java	378
streams/src/test/java/org/apache/kafka/streams/state/internals/Murmur3Test.java	37
streams/src/test/java/org/apache/kafka/streams/state/internals/NamedCacheTest.java	213
streams/src/test/java/org/apache/kafka/streams/state/internals/OffsetCheckpointTest.java	110
streams/src/test/java/org/apache/kafka/streams/state/internals/QueryableStoreProviderTest.java	96
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyKeyValueStoreFacadeTest.java	70
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreFacadeTest.java	161
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreStub.java	356
streams/src/test/java/org/apache/kafka/streams/state/internals/RecordConvertersTest.java	26
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest.java	280
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBKeyValueStoreTest.java	91
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	43
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java	614
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	335
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java	596
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentIteratorTest.java	170
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	24
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionKeySchemaTest.java	188
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionStoreBuilderTest.java	116
streams/src/test/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProviderTest.java	384
streams/src/test/java/org/apache/kafka/streams/state/internals/ThreadCacheTest.java	386
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferTest.java	825
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilderTest.java	134
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedSegmentTest.java	91
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedSegmentsTest.java	289
streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilderTest.java	161
streams/src/test/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializerTest.java	60
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowKeySchemaTest.java	219
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreBuilderTest.java	119
streams/src/test/java/org/apache/kafka/streams/state/internals/WrappingStoreProviderTest.java	57
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetricsTest.java	88
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderGaugesTest.java	210
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.java	538
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	482
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetricsTest.java	434
streams/src/test/java/org/apache/kafka/streams/tests/BrokerCompatibilityTest.java	128
streams/src/test/java/org/apache/kafka/streams/tests/EosTestClient.java	124
streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java	525
streams/src/test/java/org/apache/kafka/streams/tests/RelationalSmokeTest.java	824
streams/src/test/java/org/apache/kafka/streams/tests/RelationalSmokeTestTest.java	72
streams/src/test/java/org/apache/kafka/streams/tests/ShutdownDeadlockTest.java	58
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	226
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	507
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	96
streams/src/test/java/org/apache/kafka/streams/tests/StaticMemberTestClient.java	49
streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java	100
streams/src/test/java/org/apache/kafka/streams/tests/StreamsEosTest.java	59
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	65
streams/src/test/java/org/apache/kafka/streams/tests/StreamsStandByReplicaTest.java	122
streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	308
streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	102
streams/src/test/java/org/apache/kafka/streams/tests/SystemTestUtil.java	25
streams/src/test/java/org/apache/kafka/streams/tests/SystemTestUtilTest.java	45
streams/src/test/java/org/apache/kafka/streams/tools/StreamsResetterTest.java	226
streams/src/test/java/org/apache/kafka/streams/utils/UniqueTopicSerdeScope.java	113
streams/src/test/java/org/apache/kafka/test/GenericInMemoryKeyValueStore.java	130
streams/src/test/java/org/apache/kafka/test/GenericInMemoryTimestampedKeyValueStore.java	131
streams/src/test/java/org/apache/kafka/test/GlobalStateManagerStub.java	69
streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java	364
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/MockApiProcessor.java	105
streams/src/test/java/org/apache/kafka/test/MockApiProcessorSupplier.java	38
streams/src/test/java/org/apache/kafka/test/MockClientSupplier.java	62
streams/src/test/java/org/apache/kafka/test/MockInitializer.java	11
streams/src/test/java/org/apache/kafka/test/MockInternalProcessorContext.java	111
streams/src/test/java/org/apache/kafka/test/MockInternalTopicManager.java	50
streams/src/test/java/org/apache/kafka/test/MockKeyValueStore.java	96
streams/src/test/java/org/apache/kafka/test/MockKeyValueStoreBuilder.java	16
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	55
streams/src/test/java/org/apache/kafka/test/MockProcessorNode.java	40
streams/src/test/java/org/apache/kafka/test/MockProcessorSupplier.java	38
streams/src/test/java/org/apache/kafka/test/MockRecordCollector.java	72
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	106
streams/src/test/java/org/apache/kafka/test/MockSourceNode.java	34
streams/src/test/java/org/apache/kafka/test/MockStateRestoreListener.java	57
streams/src/test/java/org/apache/kafka/test/MockTimestampExtractor.java	9
streams/src/test/java/org/apache/kafka/test/MockValueJoiner.java	13
streams/src/test/java/org/apache/kafka/test/NoOpProcessorContext.java	112
streams/src/test/java/org/apache/kafka/test/NoOpReadOnlyStore.java	70
streams/src/test/java/org/apache/kafka/test/ReadOnlySessionStoreStub.java	87
streams/src/test/java/org/apache/kafka/test/SingletonNoOpValueTransformer.java	24
streams/src/test/java/org/apache/kafka/test/StateStoreProviderStub.java	52
streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java	186
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala	86
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/TopologyTest.scala	313
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/WordCountTest.scala	164
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/ConsumedTest.scala	45
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/KStreamTest.scala	262
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KTableTest.scala	301
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/MaterializedTest.scala	56
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/ProducedTest.scala	27
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/RepartitionedTest.scala	57
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/StreamJoinedTest.scala	40
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/SuppressedTest.scala	67
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/utils/StreamToTableJoinScalaIntegrationTestBase.scala	91
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/utils/StreamToTableJoinTestData.scala	35
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/utils/TestDriver.scala	22
streams/test-utils/src/main/java/org/apache/kafka/streams/test/ConsumerRecordFactory.java	261
streams/test-utils/src/main/java/org/apache/kafka/streams/test/OutputVerifier.java	235
streams/test-utils/src/main/java/org/apache/kafka/streams/test/TestRecord.java	119
streams/test-utils/src/test/java/org/apache/kafka/streams/MockProcessorContextTest.java	310
streams/test-utils/src/test/java/org/apache/kafka/streams/MockTimeTest.java	31
streams/test-utils/src/test/java/org/apache/kafka/streams/TestTopicsTest.java	391
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java	1534
streams/test-utils/src/test/java/org/apache/kafka/streams/internals/KeyValueStoreFacadeTest.java	127
streams/test-utils/src/test/java/org/apache/kafka/streams/internals/WindowStoreFacadeTest.java	98
streams/test-utils/src/test/java/org/apache/kafka/streams/test/ConsumerRecordFactoryTest.java	204
streams/test-utils/src/test/java/org/apache/kafka/streams/test/OutputVerifierTest.java	478
streams/test-utils/src/test/java/org/apache/kafka/streams/test/TestRecordTest.java	126
streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessorSupplier.java	50
streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessorTest.java	127
streams/upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	72
streams/upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	56
streams/upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	72
streams/upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	56
streams/upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java	66
streams/upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java	52
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	507
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	56
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	507
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	56
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	507
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	56
tools/src/test/java/org/apache/kafka/tools/PushHttpMetricsReporterTest.java	271
tools/src/test/java/org/apache/kafka/trogdor/agent/AgentTest.java	416
tools/src/test/java/org/apache/kafka/trogdor/basic/BasicPlatformTest.java	43
tools/src/test/java/org/apache/kafka/trogdor/common/CapturingCommandRunner.java	36
tools/src/test/java/org/apache/kafka/trogdor/common/ExpectedTasks.java	168
tools/src/test/java/org/apache/kafka/trogdor/common/JsonSerializationTest.java	60
tools/src/test/java/org/apache/kafka/trogdor/common/JsonUtilTest.java	45
tools/src/test/java/org/apache/kafka/trogdor/common/MiniTrogdorCluster.java	223
tools/src/test/java/org/apache/kafka/trogdor/common/StringExpanderTest.java	48
tools/src/test/java/org/apache/kafka/trogdor/common/StringFormatterTest.java	40
tools/src/test/java/org/apache/kafka/trogdor/common/TopologyTest.java	41
tools/src/test/java/org/apache/kafka/trogdor/common/WorkerUtilsTest.java	267
tools/src/test/java/org/apache/kafka/trogdor/coordinator/CoordinatorClientTest.java	56
tools/src/test/java/org/apache/kafka/trogdor/coordinator/CoordinatorTest.java	618
tools/src/test/java/org/apache/kafka/trogdor/rest/RestExceptionMapperTest.java	78
tools/src/test/java/org/apache/kafka/trogdor/task/SampleTaskController.java	9
tools/src/test/java/org/apache/kafka/trogdor/task/SampleTaskSpec.java	36
tools/src/test/java/org/apache/kafka/trogdor/task/SampleTaskWorker.java	44
tools/src/test/java/org/apache/kafka/trogdor/task/TaskSpecTest.java	27
tools/src/test/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpecTest.java	47
tools/src/test/java/org/apache/kafka/trogdor/workload/ExternalCommandWorkerTest.java	139
tools/src/test/java/org/apache/kafka/trogdor/workload/HistogramTest.java	57
tools/src/test/java/org/apache/kafka/trogdor/workload/PayloadGeneratorTest.java	194
tools/src/test/java/org/apache/kafka/trogdor/workload/ThrottleTest.java	44
tools/src/test/java/org/apache/kafka/trogdor/workload/TimeIntervalTransactionsGeneratorTest.java	21
tools/src/test/java/org/apache/kafka/trogdor/workload/TopicsSpecTest.java	60