Path	Lines of Code
clients/src/test/java/org/apache/kafka/clients/ApiVersionsTest.java	21
clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java	32
clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java	135
clients/src/test/java/org/apache/kafka/clients/CommonClientConfigsTest.java	59
clients/src/test/java/org/apache/kafka/clients/InFlightRequestsTest.java	34
clients/src/test/java/org/apache/kafka/clients/MetadataTest.java	313
clients/src/test/java/org/apache/kafka/clients/MockClient.java	344
clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java	302
clients/src/test/java/org/apache/kafka/clients/NodeApiVersionsTest.java	119
clients/src/test/java/org/apache/kafka/clients/admin/AdminClientUnitTestEnv.java	56
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java	507
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java	269
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerConfigTest.java	63
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerRecordTest.java	39
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerRecordsTest.java	33
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java	1237
clients/src/test/java/org/apache/kafka/clients/consumer/MockConsumerTest.java	36
clients/src/test/java/org/apache/kafka/clients/consumer/RangeAssignorTest.java	146
clients/src/test/java/org/apache/kafka/clients/consumer/RoundRobinAssignorTest.java	139
clients/src/test/java/org/apache/kafka/clients/consumer/SerializeCompatibilityOffsetAndMetadataTest.java	29
clients/src/test/java/org/apache/kafka/clients/consumer/StickyAssignorTest.java	549
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java	468
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java	1409
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptorsTest.java	124
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClientTest.java	201
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java	95
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java	1626
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatTest.java	46
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MockPartitionAssignor.java	24
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	242
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java	440
clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java	590
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	61
clients/src/test/java/org/apache/kafka/clients/producer/internals/BufferPoolTest.java	306
clients/src/test/java/org/apache/kafka/clients/producer/internals/DefaultPartitionerTest.java	71
clients/src/test/java/org/apache/kafka/clients/producer/internals/ProducerBatchTest.java	217
clients/src/test/java/org/apache/kafka/clients/producer/internals/ProducerInterceptorsTest.java	139
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java	685
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java	1535
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java	1850
clients/src/test/java/org/apache/kafka/common/ClusterTest.java	24
clients/src/test/java/org/apache/kafka/common/KafkaFutureTest.java	183
clients/src/test/java/org/apache/kafka/common/PartitionInfoTest.java	20
clients/src/test/java/org/apache/kafka/common/SerializeCompatibilityTopicPartitionTest.java	29
clients/src/test/java/org/apache/kafka/common/acl/AclBindingTest.java	85
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/config/AbstractConfigTest.java	271
clients/src/test/java/org/apache/kafka/common/config/ConfigDefTest.java	506
clients/src/test/java/org/apache/kafka/common/header/internals/RecordHeadersTest.java	144
clients/src/test/java/org/apache/kafka/common/internals/PartitionStatesTest.java	171
clients/src/test/java/org/apache/kafka/common/internals/TopicTest.java	67
clients/src/test/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPoolTest.java	117
clients/src/test/java/org/apache/kafka/common/metrics/FakeMetricsReporter.java	15
clients/src/test/java/org/apache/kafka/common/metrics/JmxReporterTest.java	81
clients/src/test/java/org/apache/kafka/common/metrics/KafkaMbeanTest.java	129
clients/src/test/java/org/apache/kafka/common/metrics/MetricsTest.java	455
clients/src/test/java/org/apache/kafka/common/metrics/SampleMetrics.java	7
clients/src/test/java/org/apache/kafka/common/metrics/SensorTest.java	38
clients/src/test/java/org/apache/kafka/common/metrics/stats/FrequenciesTest.java	118
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	35
clients/src/test/java/org/apache/kafka/common/network/ChannelBuildersTest.java	72
clients/src/test/java/org/apache/kafka/common/network/EchoServer.java	104
clients/src/test/java/org/apache/kafka/common/network/NetworkTestUtils.java	65
clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java	197
clients/src/test/java/org/apache/kafka/common/network/PlaintextSender.java	22
clients/src/test/java/org/apache/kafka/common/network/SaslChannelBuilderTest.java	52
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java	528
clients/src/test/java/org/apache/kafka/common/network/SslSelectorTest.java	197
clients/src/test/java/org/apache/kafka/common/network/SslSender.java	53
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java	698
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/ProtoUtilsTest.java	17
clients/src/test/java/org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java	234
clients/src/test/java/org/apache/kafka/common/record/AbstractLegacyRecordBatchTest.java	156
clients/src/test/java/org/apache/kafka/common/record/ByteBufferLogInputStreamTest.java	84
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	319
clients/src/test/java/org/apache/kafka/common/record/DefaultRecordTest.java	183
clients/src/test/java/org/apache/kafka/common/record/EndTransactionMarkerTest.java	44
clients/src/test/java/org/apache/kafka/common/record/FileLogInputStreamTest.java	204
clients/src/test/java/org/apache/kafka/common/record/FileRecordsTest.java	354
clients/src/test/java/org/apache/kafka/common/record/KafkaLZ4Test.java	261
clients/src/test/java/org/apache/kafka/common/record/LegacyRecordTest.java	99
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsBuilderTest.java	535
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java	668
clients/src/test/java/org/apache/kafka/common/record/SimpleLegacyRecordTest.java	55
clients/src/test/java/org/apache/kafka/common/record/SimpleMemoryRecordsTest.java	15
clients/src/test/java/org/apache/kafka/common/requests/ApiVersionsResponseTest.java	61
clients/src/test/java/org/apache/kafka/common/requests/ByteBufferChannel.java	46
clients/src/test/java/org/apache/kafka/common/requests/LeaderAndIsrResponseTest.java	43
clients/src/test/java/org/apache/kafka/common/requests/ProduceRequestTest.java	140
clients/src/test/java/org/apache/kafka/common/requests/RequestContextTest.java	45
clients/src/test/java/org/apache/kafka/common/requests/RequestHeaderTest.java	47
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java	997
clients/src/test/java/org/apache/kafka/common/requests/StopReplicaResponseTest.java	37
clients/src/test/java/org/apache/kafka/common/resource/ResourceTypeTest.java	59
clients/src/test/java/org/apache/kafka/common/security/JaasContextTest.java	244
clients/src/test/java/org/apache/kafka/common/security/TestSecurityConfig.java	22
clients/src/test/java/org/apache/kafka/common/security/auth/DefaultKafkaPrincipalBuilderTest.java	114
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	113
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java	832
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticatorTest.java	84
clients/src/test/java/org/apache/kafka/common/security/authenticator/TestDigestLoginModule.java	79
clients/src/test/java/org/apache/kafka/common/security/authenticator/TestJaasConfig.java	91
clients/src/test/java/org/apache/kafka/common/security/kerberos/KerberosNameTest.java	74
clients/src/test/java/org/apache/kafka/common/security/plain/PlainSaslServerTest.java	46
clients/src/test/java/org/apache/kafka/common/security/scram/ScramCredentialUtilsTest.java	64
clients/src/test/java/org/apache/kafka/common/security/scram/ScramFormatterTest.java	56
clients/src/test/java/org/apache/kafka/common/security/scram/ScramMessagesTest.java	248
clients/src/test/java/org/apache/kafka/common/security/scram/ScramSaslServerTest.java	46
clients/src/test/java/org/apache/kafka/common/security/ssl/SslFactoryTest.java	101
clients/src/test/java/org/apache/kafka/common/serialization/SerializationTest.java	121
clients/src/test/java/org/apache/kafka/common/utils/AbstractIteratorTest.java	45
clients/src/test/java/org/apache/kafka/common/utils/Base64Test.java	22
clients/src/test/java/org/apache/kafka/common/utils/ByteBufferOutputStreamTest.java	73
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java	188
clients/src/test/java/org/apache/kafka/common/utils/ChecksumsTest.java	58
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/JavaTest.java	65
clients/src/test/java/org/apache/kafka/common/utils/MappedByteBuffersTest.java	16
clients/src/test/java/org/apache/kafka/common/utils/MockScheduler.java	82
clients/src/test/java/org/apache/kafka/common/utils/MockTime.java	63
clients/src/test/java/org/apache/kafka/common/utils/MockTimeTest.java	29
clients/src/test/java/org/apache/kafka/common/utils/SanitizerTest.java	56
clients/src/test/java/org/apache/kafka/common/utils/SecurityUtilsTest.java	21
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/UtilsTest.java	364
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	39
clients/src/test/java/org/apache/kafka/test/MockMetricsReporter.java	27
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	129
clients/src/test/java/org/apache/kafka/test/MockSerializer.java	33
clients/src/test/java/org/apache/kafka/test/TestCondition.java	4
clients/src/test/java/org/apache/kafka/test/TestSslUtils.java	197
clients/src/test/java/org/apache/kafka/test/TestUtils.java	222
connect/api/src/test/java/org/apache/kafka/connect/connector/ConnectorReconfigurationTest.java	57
connect/api/src/test/java/org/apache/kafka/connect/data/ConnectSchemaTest.java	235
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	411
connect/api/src/test/java/org/apache/kafka/connect/data/StructTest.java	250
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	126
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	439
connect/api/src/test/java/org/apache/kafka/connect/sink/SinkRecordTest.java	98
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/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkConnectorTest.java	58
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkTaskTest.java	42
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSourceConnectorTest.java	69
connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSourceTaskTest.java	141
connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterTest.java	645
connect/runtime/src/test/java/org/apache/kafka/connect/converters/ByteArrayConverterTest.java	60
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java	199
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectMetricsTest.java	135
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectorConfigTest.java	142
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/MockConnectMetrics.java	85
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitterTest.java	132
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/StateTrackerTest.java	69
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	147
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConnectorTest.java	329
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java	1074
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java	529
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java	624
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java	248
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java	715
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java	1136
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.java	392
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	235
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestServerTest.java	173
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	459
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResourceTest.java	469
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	98
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java	501
connect/runtime/src/test/java/org/apache/kafka/connect/storage/FileOffsetBackingStoreTest.java	86
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaConfigBackingStoreTest.java	630
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java	349
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreTest.java	292
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	36
connect/runtime/src/test/java/org/apache/kafka/connect/util/KafkaBasedLogTest.java	386
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	113
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/CastTest.java	281
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ExtractFieldTest.java	55
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/FlattenTest.java	190
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	74
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/MaskFieldTest.java	123
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	60
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	250
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	57
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidatorTest.java	18
core/src/test/scala/integration/kafka/admin/BrokerApiVersionsCommandTest.scala	39
core/src/test/scala/integration/kafka/admin/ReassignPartitionsIntegrationTest.scala	26
core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala	833
core/src/test/scala/integration/kafka/api/AdminClientWithPoliciesIntegrationTest.scala	142
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala	1180
core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala	230
core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala	351
core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala	195
core/src/test/scala/integration/kafka/api/ClientIdQuotaTest.scala	37
core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala	319
core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala	57
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala	273
core/src/test/scala/integration/kafka/api/EndToEndClusterIdTest.scala	158
core/src/test/scala/integration/kafka/api/FixedPortTestUtils.scala	26
core/src/test/scala/integration/kafka/api/GroupCoordinatorIntegrationTest.scala	43
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala	81
core/src/test/scala/integration/kafka/api/LegacyAdminClientTest.scala	202
core/src/test/scala/integration/kafka/api/LogAppendTimeTest.scala	54
core/src/test/scala/integration/kafka/api/MetricsTest.scala	230
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala	1206
core/src/test/scala/integration/kafka/api/PlaintextEndToEndAuthorizationTest.scala	44
core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala	78
core/src/test/scala/integration/kafka/api/ProducerBounceTest.scala	115
core/src/test/scala/integration/kafka/api/ProducerCompressionTest.scala	78
core/src/test/scala/integration/kafka/api/ProducerFailureHandlingTest.scala	183
core/src/test/scala/integration/kafka/api/RackAwareAutoTopicCreationTest.scala	39
core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala	194
core/src/test/scala/integration/kafka/api/SaslEndToEndAuthorizationTest.scala	50
core/src/test/scala/integration/kafka/api/SaslGssapiSslEndToEndAuthorizationTest.scala	11
core/src/test/scala/integration/kafka/api/SaslMultiMechanismConsumerTest.scala	70
core/src/test/scala/integration/kafka/api/SaslPlainPlaintextConsumerTest.scala	34
core/src/test/scala/integration/kafka/api/SaslPlainSslEndToEndAuthorizationTest.scala	34
core/src/test/scala/integration/kafka/api/SaslPlaintextConsumerTest.scala	17
core/src/test/scala/integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala	25
core/src/test/scala/integration/kafka/api/SaslSetup.scala	107
core/src/test/scala/integration/kafka/api/SaslSslAdminClientIntegrationTest.scala	232
core/src/test/scala/integration/kafka/api/SaslSslConsumerTest.scala	21
core/src/test/scala/integration/kafka/api/SslConsumerTest.scala	7
core/src/test/scala/integration/kafka/api/SslEndToEndAuthorizationTest.scala	45
core/src/test/scala/integration/kafka/api/SslProducerSendTest.scala	7
core/src/test/scala/integration/kafka/api/TransactionsBounceTest.scala	138
core/src/test/scala/integration/kafka/api/TransactionsTest.scala	448
core/src/test/scala/integration/kafka/api/UserClientIdQuotaTest.scala	44
core/src/test/scala/integration/kafka/api/UserQuotaTest.scala	46
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala	715
core/src/test/scala/integration/kafka/server/MultipleListenersWithAdditionalJaasContextTest.scala	22
core/src/test/scala/integration/kafka/server/MultipleListenersWithDefaultJaasContextTest.scala	12
core/src/test/scala/integration/kafka/server/MultipleListenersWithSameSecurityProtocolBaseTest.scala	109
core/src/test/scala/integration/kafka/server/ReplicaFetcherThreadFatalErrorTest.scala	97
core/src/test/scala/integration/kafka/tools/MirrorMakerIntegrationTest.scala	46
core/src/test/scala/kafka/common/InterBrokerSendThreadTest.scala	85
core/src/test/scala/kafka/security/minikdc/MiniKdc.scala	313
core/src/test/scala/kafka/tools/ReplicaVerificationToolTest.scala	35
core/src/test/scala/kafka/tools/TestLogCleaning.scala	263
core/src/test/scala/kafka/utils/LoggingTest.scala	15
core/src/test/scala/other/kafka/ReplicationQuotasTestRig.scala	244
core/src/test/scala/other/kafka/StressTestLog.scala	89
core/src/test/scala/other/kafka/TestCrcPerformance.scala	20
core/src/test/scala/other/kafka/TestKafkaAppender.scala	25
core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala	185
core/src/test/scala/other/kafka/TestOffsetManager.scala	243
core/src/test/scala/other/kafka/TestPurgatoryPerformance.scala	219
core/src/test/scala/other/kafka/TestTruncate.scala	17
core/src/test/scala/unit/kafka/KafkaConfigTest.scala	76
core/src/test/scala/unit/kafka/admin/AclCommandTest.scala	124
core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala	157
core/src/test/scala/unit/kafka/admin/AdminRackAwareTest.scala	162
core/src/test/scala/unit/kafka/admin/AdminTest.scala	429
core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala	384
core/src/test/scala/unit/kafka/admin/ConsumerGroupCommandTest.scala	142
core/src/test/scala/unit/kafka/admin/DeleteConsumerGroupTest.scala	164
core/src/test/scala/unit/kafka/admin/DeleteConsumerGroupsTest.scala	175
core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala	234
core/src/test/scala/unit/kafka/admin/DescribeConsumerGroupTest.scala	486
core/src/test/scala/unit/kafka/admin/ListConsumerGroupTest.scala	55
core/src/test/scala/unit/kafka/admin/RackAwareTest.scala	55
core/src/test/scala/unit/kafka/admin/ReassignPartitionsClusterTest.scala	408
core/src/test/scala/unit/kafka/admin/ReassignPartitionsCommandArgsTest.scala	180
core/src/test/scala/unit/kafka/admin/ReassignPartitionsCommandTest.scala	311
core/src/test/scala/unit/kafka/admin/ReplicationQuotaUtils.scala	37
core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala	386
core/src/test/scala/unit/kafka/admin/TestAdminUtils.scala	10
core/src/test/scala/unit/kafka/admin/TopicCommandTest.scala	154
core/src/test/scala/unit/kafka/api/ApiUtilsTest.scala	51
core/src/test/scala/unit/kafka/api/ApiVersionTest.scala	45
core/src/test/scala/unit/kafka/api/FetchRequestTest.scala	38
core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala	185
core/src/test/scala/unit/kafka/cluster/BrokerEndPointTest.scala	183
core/src/test/scala/unit/kafka/cluster/ReplicaTest.scala	103
core/src/test/scala/unit/kafka/common/ConfigTest.scala	63
core/src/test/scala/unit/kafka/common/ZkNodeChangeNotificationListenerTest.scala	34
core/src/test/scala/unit/kafka/consumer/ConsumerIteratorTest.scala	84
core/src/test/scala/unit/kafka/consumer/PartitionAssignorTest.scala	201
core/src/test/scala/unit/kafka/consumer/TopicFilterTest.scala	55
core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala	306
core/src/test/scala/unit/kafka/controller/ControllerEventManagerTest.scala	52
core/src/test/scala/unit/kafka/controller/ControllerFailoverTest.scala	61
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala	302
core/src/test/scala/unit/kafka/controller/ControllerTestUtils.scala	15
core/src/test/scala/unit/kafka/controller/PartitionLeaderElectionAlgorithmsTest.scala	146
core/src/test/scala/unit/kafka/controller/PartitionStateMachineTest.scala	260
core/src/test/scala/unit/kafka/controller/ReplicaStateMachineTest.scala	308
core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala	173
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala	253
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala	1230
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala	1169
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataTest.scala	359
core/src/test/scala/unit/kafka/coordinator/group/MemberMetadataTest.scala	56
core/src/test/scala/unit/kafka/coordinator/transaction/ProducerIdManagerTest.scala	59
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorConcurrencyTest.scala	309
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala	581
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionLogTest.scala	67
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala	352
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandlerTest.scala	202
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMetadataTest.scala	145
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionStateManagerTest.scala	456
core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala	76
core/src/test/scala/unit/kafka/integration/FetcherTest.scala	62
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala	77
core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala	98
core/src/test/scala/unit/kafka/integration/MinIsrConfigTest.scala	14
core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala	208
core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala	27
core/src/test/scala/unit/kafka/integration/TopicMetadataTest.scala	208
core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala	171
core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala	82
core/src/test/scala/unit/kafka/javaapi/message/BaseMessageSetTestCases.scala	41
core/src/test/scala/unit/kafka/javaapi/message/ByteBufferMessageSetTest.scala	23
core/src/test/scala/unit/kafka/log/AbstractLogCleanerIntegrationTest.scala	92
core/src/test/scala/unit/kafka/log/BrokerCompressionTest.scala	52
core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala	248
core/src/test/scala/unit/kafka/log/LogCleanerLagIntegrationTest.scala	86
core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala	169
core/src/test/scala/unit/kafka/log/LogCleanerTest.scala	946
core/src/test/scala/unit/kafka/log/LogConfigTest.scala	87
core/src/test/scala/unit/kafka/log/LogManagerTest.scala	231
core/src/test/scala/unit/kafka/log/LogSegmentTest.scala	366
core/src/test/scala/unit/kafka/log/LogTest.scala	2287
core/src/test/scala/unit/kafka/log/LogValidatorTest.scala	977
core/src/test/scala/unit/kafka/log/OffsetIndexTest.scala	153
core/src/test/scala/unit/kafka/log/OffsetMapTest.scala	62
core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala	566
core/src/test/scala/unit/kafka/log/TimeIndexTest.scala	92
core/src/test/scala/unit/kafka/log/TransactionIndexTest.scala	123
core/src/test/scala/unit/kafka/message/BaseMessageSetTestCases.scala	86
core/src/test/scala/unit/kafka/message/ByteBufferMessageSetTest.scala	115
core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala	58
core/src/test/scala/unit/kafka/message/MessageTest.scala	99
core/src/test/scala/unit/kafka/metrics/KafkaTimerTest.scala	33
core/src/test/scala/unit/kafka/metrics/MetricsTest.scala	142
core/src/test/scala/unit/kafka/network/SocketServerTest.scala	840
core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala	390
core/src/test/scala/unit/kafka/producer/ProducerTest.scala	260
core/src/test/scala/unit/kafka/producer/SyncProducerTest.scala	180
core/src/test/scala/unit/kafka/security/auth/AclTest.scala	22
core/src/test/scala/unit/kafka/security/auth/OperationTest.scala	17
core/src/test/scala/unit/kafka/security/auth/PermissionTypeTest.scala	29
core/src/test/scala/unit/kafka/security/auth/ResourceTypeTest.scala	29
core/src/test/scala/unit/kafka/security/auth/SimpleAclAuthorizerTest.scala	313
core/src/test/scala/unit/kafka/security/auth/ZkAuthorizationTest.scala	205
core/src/test/scala/unit/kafka/security/token/delegation/DelegationTokenManagerTest.scala	211
core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala	110
core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala	138
core/src/test/scala/unit/kafka/server/AddPartitionsToTxnRequestTest.scala	43
core/src/test/scala/unit/kafka/server/AdvertiseBrokerTest.scala	64
core/src/test/scala/unit/kafka/server/AlterReplicaLogDirsRequestTest.scala	78
core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala	37
core/src/test/scala/unit/kafka/server/BaseRequestTest.scala	112
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala	275
core/src/test/scala/unit/kafka/server/CreateTopicsRequestTest.scala	119
core/src/test/scala/unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala	102
core/src/test/scala/unit/kafka/server/DelayedOperationTest.scala	203
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsOnPlainTextTest.scala	44
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsTest.scala	75
core/src/test/scala/unit/kafka/server/DelegationTokenRequestsWithDisableTokenFeatureTest.scala	55
core/src/test/scala/unit/kafka/server/DeleteTopicsRequestTest.scala	80
core/src/test/scala/unit/kafka/server/DescribeLogDirsRequestTest.scala	40
core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala	114
core/src/test/scala/unit/kafka/server/DynamicConfigChangeTest.scala	215
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/FetchRequestTest.scala	270
core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala	125
core/src/test/scala/unit/kafka/server/ISRExpirationTest.scala	158
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala	395
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala	608
core/src/test/scala/unit/kafka/server/KafkaMetricReporterClusterIdTest.scala	76
core/src/test/scala/unit/kafka/server/LeaderElectionTest.scala	122
core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala	152
core/src/test/scala/unit/kafka/server/LogOffsetTest.scala	213
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala	155
core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala	247
core/src/test/scala/unit/kafka/server/MetadataRequestTest.scala	171
core/src/test/scala/unit/kafka/server/OffsetCommitTest.scala	237
core/src/test/scala/unit/kafka/server/ProduceRequestTest.scala	62
core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala	53
core/src/test/scala/unit/kafka/server/ReplicaFetcherThreadTest.scala	278
core/src/test/scala/unit/kafka/server/ReplicaManagerQuotasTest.scala	170
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala	482
core/src/test/scala/unit/kafka/server/ReplicationQuotaManagerTest.scala	66
core/src/test/scala/unit/kafka/server/ReplicationQuotasTest.scala	144
core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala	378
core/src/test/scala/unit/kafka/server/SaslApiVersionsRequestTest.scala	78
core/src/test/scala/unit/kafka/server/ServerGenerateBrokerIdTest.scala	154
core/src/test/scala/unit/kafka/server/ServerGenerateClusterIdTest.scala	87
core/src/test/scala/unit/kafka/server/ServerMetricsTest.scala	27
core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala	147
core/src/test/scala/unit/kafka/server/ServerStartupTest.scala	85
core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala	134
core/src/test/scala/unit/kafka/server/ThrottledResponseExpirationTest.scala	59
core/src/test/scala/unit/kafka/server/checkpoints/LeaderEpochCheckpointFileTest.scala	31
core/src/test/scala/unit/kafka/server/checkpoints/OffsetCheckpointFileTest.scala	50
core/src/test/scala/unit/kafka/server/epoch/EpochDrivenReplicationProtocolAcceptanceTest.scala	245
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala	372
core/src/test/scala/unit/kafka/server/epoch/LeaderEpochIntegrationTest.scala	177
core/src/test/scala/unit/kafka/server/epoch/OffsetsForLeaderEpochTest.scala	69
core/src/test/scala/unit/kafka/server/epoch/util/ReplicaFetcherMockBlockingSend.scala	44
core/src/test/scala/unit/kafka/tools/ConsoleConsumerTest.scala	340
core/src/test/scala/unit/kafka/tools/ConsoleProducerTest.scala	50
core/src/test/scala/unit/kafka/tools/ConsumerPerformanceTest.scala	35
core/src/test/scala/unit/kafka/tools/MirrorMakerTest.scala	51
core/src/test/scala/unit/kafka/utils/CommandLineUtilsTest.scala	29
core/src/test/scala/unit/kafka/utils/CoreUtilsTest.scala	212
core/src/test/scala/unit/kafka/utils/IteratorTemplateTest.scala	36
core/src/test/scala/unit/kafka/utils/JaasTestUtils.scala	199
core/src/test/scala/unit/kafka/utils/JsonTest.scala	92
core/src/test/scala/unit/kafka/utils/MockScheduler.scala	50
core/src/test/scala/unit/kafka/utils/MockTime.scala	10
core/src/test/scala/unit/kafka/utils/ReplicationUtilsTest.scala	60
core/src/test/scala/unit/kafka/utils/SchedulerTest.scala	78
core/src/test/scala/unit/kafka/utils/ShutdownableThreadTest.scala	30
core/src/test/scala/unit/kafka/utils/TestUtils.scala	1118
core/src/test/scala/unit/kafka/utils/ZkUtilsTest.scala	66
core/src/test/scala/unit/kafka/utils/json/JsonValueTest.scala	160
core/src/test/scala/unit/kafka/utils/timer/MockTimer.scala	43
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	229
core/src/test/scala/unit/kafka/zk/EmbeddedZookeeper.scala	30
core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala	350
core/src/test/scala/unit/kafka/zk/ZKEphemeralTest.scala	118
core/src/test/scala/unit/kafka/zk/ZKPathTest.scala	102
core/src/test/scala/unit/kafka/zk/ZkFourLetterWords.scala	21
core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala	68
core/src/test/scala/unit/kafka/zookeeper/ZooKeeperClientTest.scala	370
log4j-appender/src/test/java/org/apache/kafka/log4jappender/KafkaLog4jAppenderTest.java	63
log4j-appender/src/test/java/org/apache/kafka/log4jappender/MockKafkaLog4jAppender.java	26
streams/src/test/java/org/apache/kafka/streams/InternalTopologyAccessor.java	7
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java	461
streams/src/test/java/org/apache/kafka/streams/KeyValueTest.java	40
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java	231
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java	494
streams/src/test/java/org/apache/kafka/streams/TopologyTest.java	571
streams/src/test/java/org/apache/kafka/streams/errors/AlwaysContinueProductionExceptionHandler.java	13
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java	207
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java	438
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java	615
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableIntegrationTest.java	285
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java	148
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationDedupIntegrationTest.java	255
streams/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java	610
streams/src/test/java/org/apache/kafka/streams/integration/KStreamsFineGrainedAutoResetIntegrationTest.java	248
streams/src/test/java/org/apache/kafka/streams/integration/KTableSourceTopicRestartIntegrationTest.java	188
streams/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.java	169
streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java	870
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java	330
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java	65
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationWithSslTest.java	52
streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java	249
streams/src/test/java/org/apache/kafka/streams/integration/StreamStreamJoinIntegrationTest.java	207
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinIntegrationTest.java	77
streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java	454
streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java	193
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java	249
streams/src/test/java/org/apache/kafka/streams/integration/utils/KafkaEmbedded.java	108
streams/src/test/java/org/apache/kafka/streams/kstream/JoinWindowsTest.java	91
streams/src/test/java/org/apache/kafka/streams/kstream/KStreamBuilderTest.java	331
streams/src/test/java/org/apache/kafka/streams/kstream/MaterializedTest.java	30
streams/src/test/java/org/apache/kafka/streams/kstream/PrintedTest.java	93
streams/src/test/java/org/apache/kafka/streams/kstream/SessionWindowsTest.java	53
streams/src/test/java/org/apache/kafka/streams/kstream/TimeWindowsTest.java	116
streams/src/test/java/org/apache/kafka/streams/kstream/UnlimitedWindowsTest.java	49
streams/src/test/java/org/apache/kafka/streams/kstream/WindowTest.java	57
streams/src/test/java/org/apache/kafka/streams/kstream/WindowsTest.java	34
streams/src/test/java/org/apache/kafka/streams/kstream/internals/AbstractStreamTest.java	91
streams/src/test/java/org/apache/kafka/streams/kstream/internals/GlobalKTableJoinsTest.java	80
streams/src/test/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilderTest.java	316
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImplTest.java	588
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImplTest.java	261
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamBranchTest.java	78
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFilterTest.java	66
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapTest.java	48
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValuesTest.java	66
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamForeachTest.java	69
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoinTest.java	125
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableLeftJoinTest.java	125
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java	443
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java	443
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamLeftJoinTest.java	193
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinTest.java	107
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableLeftJoinTest.java	107
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamMapTest.java	58
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamMapValuesTest.java	64
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamPeekTest.java	56
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamPrintTest.java	68
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSelectKeyTest.java	59
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregateProcessorTest.java	224
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformTest.java	63
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValuesTest.java	168
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregateTest.java	254
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableAggregateTest.java	327
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableFilterTest.java	385
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableForeachTest.java	86
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableImplTest.java	406
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoinTest.java	239
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinTest.java	285
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoinTest.java	242
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapKeysTest.java	60
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableMapValuesTest.java	273
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java	129
streams/src/test/java/org/apache/kafka/streams/kstream/internals/MaterializedInternalTest.java	48
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionKeySerdeTest.java	76
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowTest.java	68
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java	226
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowTest.java	65
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImplTest.java	193
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	119
streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java	587
streams/src/test/java/org/apache/kafka/streams/perf/YahooBenchmark.java	264
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/TopologyBuilderTest.java	619
streams/src/test/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestampTest.java	32
streams/src/test/java/org/apache/kafka/streams/processor/WallclockTimestampExtractorTest.java	34
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.java	146
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractTaskTest.java	215
streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java	374
streams/src/test/java/org/apache/kafka/streams/processor/internals/CompositeRestoreListenerTest.java	158
streams/src/test/java/org/apache/kafka/streams/processor/internals/CopartitionedTopicsValidatorTest.java	92
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java	564
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateTaskTest.java	178
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java	224
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicConfigTest.java	34
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java	152
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java	612
streams/src/test/java/org/apache/kafka/streams/processor/internals/KeyValueStoreMaterializerTest.java	98
streams/src/test/java/org/apache/kafka/streams/processor/internals/MinTimestampTrackerTest.java	50
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockChangelogReader.java	29
streams/src/test/java/org/apache/kafka/streams/processor/internals/MockStreamsMetrics.java	9
streams/src/test/java/org/apache/kafka/streams/processor/internals/PartitionGroupTest.java	132
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java	101
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java	599
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java	457
streams/src/test/java/org/apache/kafka/streams/processor/internals/PunctuationQueueTest.java	100
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	241
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordContextStub.java	32
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordDeserializerTest.java	69
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordQueueTest.java	183
streams/src/test/java/org/apache/kafka/streams/processor/internals/SingleGroupPartitionGrouperStub.java	22
streams/src/test/java/org/apache/kafka/streams/processor/internals/SinkNodeTest.java	83
streams/src/test/java/org/apache/kafka/streams/processor/internals/SourceNodeTest.java	40
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java	322
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	295
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerStub.java	38
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateRestorerTest.java	70
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java	412
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignorTest.java	855
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java	893
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java	763
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsMetadataStateTest.java	254
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsMetricsImplTest.java	75
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java	543
streams/src/test/java/org/apache/kafka/streams/processor/internals/WrappedBatchingStateRestoreCallbackTest.java	25
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfoTest.java	66
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/ClientStateTest.java	129
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignorTest.java	525
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfoTest.java	61
streams/src/test/java/org/apache/kafka/streams/state/KeyValueStoreTestDriver.java	163
streams/src/test/java/org/apache/kafka/streams/state/NoOpWindowStore.java	65
streams/src/test/java/org/apache/kafka/streams/state/StateSerdesTest.java	59
streams/src/test/java/org/apache/kafka/streams/state/StoresTest.java	174
streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java	205
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java	272
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java	318
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingWindowStoreTest.java	309
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.java	142
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStoreTest.java	123
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStoreTest.java	89
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStoreTest.java	222
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStoreTest.java	116
streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStoreTest.java	173
streams/src/test/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIteratorTest.java	64
streams/src/test/java/org/apache/kafka/streams/state/internals/FilteredCacheIteratorTest.java	95
streams/src/test/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProviderTest.java	35
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueLoggedStoreTest.java	50
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStoreTest.java	41
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryLRUCacheStoreTest.java	118
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilderTest.java	105
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreIteratorTest.java	146
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedSessionStoreIteratorTest.java	87
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedWindowStoreIteratorTest.java	92
streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest.java	110
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueBytesStoreTest.java	144
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredSessionStoreTest.java	180
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreTest.java	142
streams/src/test/java/org/apache/kafka/streams/state/internals/NamedCacheTest.java	255
streams/src/test/java/org/apache/kafka/streams/state/internals/OffsetCheckpointTest.java	43
streams/src/test/java/org/apache/kafka/streams/state/internals/QueryableStoreProviderTest.java	57
streams/src/test/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreStub.java	207
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBKeyValueStoreSupplierTest.java	132
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBKeyValueStoreTest.java	102
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStoreTest.java	230
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSessionStoreSupplierTest.java	107
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSessionStoreTest.java	183
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java	247
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreSupplierTest.java	145
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBWindowStoreTest.java	729
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentIteratorTest.java	109
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentedCacheFunctionTest.java	85
streams/src/test/java/org/apache/kafka/streams/state/internals/SegmentsTest.java	218
streams/src/test/java/org/apache/kafka/streams/state/internals/SerializedKeyValueIteratorTest.java	63
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionKeySchemaTest.java	126
streams/src/test/java/org/apache/kafka/streams/state/internals/SessionStoreBuilderTest.java	104
streams/src/test/java/org/apache/kafka/streams/state/internals/StateStoreTestUtils.java	33
streams/src/test/java/org/apache/kafka/streams/state/internals/StoreChangeLoggerTest.java	59
streams/src/test/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProviderTest.java	188
streams/src/test/java/org/apache/kafka/streams/state/internals/ThreadCacheTest.java	432
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowKeySchemaTest.java	127
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreBuilderTest.java	99
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreUtilsTest.java	22
streams/src/test/java/org/apache/kafka/streams/state/internals/WrappingStoreProviderTest.java	44
streams/src/test/java/org/apache/kafka/streams/tests/BrokerCompatibilityTest.java	111
streams/src/test/java/org/apache/kafka/streams/tests/EosTestClient.java	179
streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java	508
streams/src/test/java/org/apache/kafka/streams/tests/ShutdownDeadlockTest.java	63
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java	195
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java	527
streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java	105
streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java	89
streams/src/test/java/org/apache/kafka/streams/tests/StreamsEosTest.java	38
streams/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java	36
streams/src/test/java/org/apache/kafka/streams/tools/StreamsResetterTest.java	217
streams/src/test/java/org/apache/kafka/test/GlobalStateManagerStub.java	61
streams/src/test/java/org/apache/kafka/test/KStreamTestDriver.java	242
streams/src/test/java/org/apache/kafka/test/KTableValueGetterStub.java	21
streams/src/test/java/org/apache/kafka/test/KeyValueIteratorStub.java	28
streams/src/test/java/org/apache/kafka/test/MockAggregator.java	14
streams/src/test/java/org/apache/kafka/test/MockBatchingStateRestoreListener.java	22
streams/src/test/java/org/apache/kafka/test/MockClientSupplier.java	55
streams/src/test/java/org/apache/kafka/test/MockInitializer.java	11
streams/src/test/java/org/apache/kafka/test/MockInternalTopicManager.java	42
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/MockProcessorContext.java	234
streams/src/test/java/org/apache/kafka/test/MockProcessorNode.java	44
streams/src/test/java/org/apache/kafka/test/MockProcessorSupplier.java	80
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	103
streams/src/test/java/org/apache/kafka/test/MockSourceNode.java	35
streams/src/test/java/org/apache/kafka/test/MockStateRestoreListener.java	61
streams/src/test/java/org/apache/kafka/test/MockStateStore.java	55
streams/src/test/java/org/apache/kafka/test/MockStateStoreSupplier.java	38
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	61
streams/src/test/java/org/apache/kafka/test/NoOpReadOnlyStore.java	70
streams/src/test/java/org/apache/kafka/test/NoOpRecordCollector.java	33
streams/src/test/java/org/apache/kafka/test/ProcessorTopologyTestDriver.java	262
streams/src/test/java/org/apache/kafka/test/ReadOnlySessionStoreStub.java	91
streams/src/test/java/org/apache/kafka/test/SegmentedBytesStoreStub.java	79
streams/src/test/java/org/apache/kafka/test/StateStoreProviderStub.java	31
streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java	62
streams/test-utils/src/main/java/org/apache/kafka/streams/test/ConsumerRecordFactory.java	182
streams/test-utils/src/main/java/org/apache/kafka/streams/test/OutputVerifier.java	109
streams/test-utils/src/test/java/org/apache/kafka/streams/MockTimeTest.java	31
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java	547
streams/test-utils/src/test/java/org/apache/kafka/streams/test/ConsumerRecordFactoryTest.java	199
streams/test-utils/src/test/java/org/apache/kafka/streams/test/OutputVerifierTest.java	477
tests/MANIFEST.in	15
tests/docker/run_tests.sh	11
tests/docker/ssh/id_rsa.pub	1
tests/kafkatest/__init__.py	1
tests/kafkatest/benchmarks/__init__.py	1
tests/kafkatest/benchmarks/core/__init__.py	1
tests/kafkatest/benchmarks/core/benchmark_test.py	196
tests/kafkatest/benchmarks/streams/__init__.py	1
tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py	59
tests/kafkatest/directory_layout/__init__.py	1
tests/kafkatest/directory_layout/kafka_path.py	66
tests/kafkatest/sanity_checks/__init__.py	1
tests/kafkatest/sanity_checks/test_console_consumer.py	62
tests/kafkatest/sanity_checks/test_kafka_version.py	30
tests/kafkatest/sanity_checks/test_performance_services.py	56
tests/kafkatest/sanity_checks/test_verifiable_producer.py	41
tests/kafkatest/services/__init__.py	1
tests/kafkatest/services/connect.py	325
tests/kafkatest/services/console_consumer.py	186
tests/kafkatest/services/kafka/__init__.py	2
tests/kafkatest/services/kafka/config.py	20
tests/kafkatest/services/kafka/config_property.py	26
tests/kafkatest/services/kafka/kafka.py	451
tests/kafkatest/services/kafka/util.py	2
tests/kafkatest/services/kafka_log4j_appender.py	54
tests/kafkatest/services/mirror_maker.py	101
tests/kafkatest/services/monitor/__init__.py	1
tests/kafkatest/services/monitor/http.py	130
tests/kafkatest/services/monitor/jmx.py	86
tests/kafkatest/services/performance/__init__.py	4
tests/kafkatest/services/performance/consumer_performance.py	109
tests/kafkatest/services/performance/end_to_end_latency.py	86
tests/kafkatest/services/performance/performance.py	34
tests/kafkatest/services/performance/producer_performance.py	123
tests/kafkatest/services/performance/streams_performance.py	17
tests/kafkatest/services/replica_verification_tool.py	54
tests/kafkatest/services/security/__init__.py	1
tests/kafkatest/services/security/kafka_acls.py	48
tests/kafkatest/services/security/minikdc.py	80
tests/kafkatest/services/security/security_config.py	194
tests/kafkatest/services/simple_consumer_shell.py	41
tests/kafkatest/services/streams.py	144
tests/kafkatest/services/transactional_message_copier.py	144
tests/kafkatest/services/trogdor/__init__.py	1
tests/kafkatest/services/trogdor/files_unreadable_fault_spec.py	14
tests/kafkatest/services/trogdor/kibosh.py	84
tests/kafkatest/services/trogdor/network_partition_fault_spec.py	6
tests/kafkatest/services/trogdor/no_op_task_spec.py	5
tests/kafkatest/services/trogdor/process_stop_fault_spec.py	7
tests/kafkatest/services/trogdor/produce_bench_workload.py	28
tests/kafkatest/services/trogdor/round_trip_workload.py	25
tests/kafkatest/services/trogdor/task_spec.py	19
tests/kafkatest/services/trogdor/trogdor.py	191
tests/kafkatest/services/verifiable_client.py	97
tests/kafkatest/services/verifiable_consumer.py	273
tests/kafkatest/services/verifiable_producer.py	184
tests/kafkatest/services/zookeeper.py	109
tests/kafkatest/tests/__init__.py	1
tests/kafkatest/tests/client/__init__.py	1
tests/kafkatest/tests/client/client_compatibility_features_test.py	77
tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py	48
tests/kafkatest/tests/client/compression_test.py	45
tests/kafkatest/tests/client/consumer_rolling_upgrade_test.py	46
tests/kafkatest/tests/client/consumer_test.py	177
tests/kafkatest/tests/client/message_format_change_test.py	58
tests/kafkatest/tests/client/pluggable_test.py	24
tests/kafkatest/tests/client/quota_test.py	156
tests/kafkatest/tests/connect/__init__.py	1
tests/kafkatest/tests/connect/connect_distributed_test.py	356
tests/kafkatest/tests/connect/connect_rest_test.py	132
tests/kafkatest/tests/connect/connect_test.py	75
tests/kafkatest/tests/core/__init__.py	1
tests/kafkatest/tests/core/compatibility_test_new_broker_test.py	56
tests/kafkatest/tests/core/consumer_group_command_test.py	66
tests/kafkatest/tests/core/get_offset_shell_test.py	51
tests/kafkatest/tests/core/log_dir_failure_test.py	95
tests/kafkatest/tests/core/mirror_maker_test.py	98
tests/kafkatest/tests/core/produce_bench_test.py	36
tests/kafkatest/tests/core/reassign_partitions_test.py	87
tests/kafkatest/tests/core/replication_test.py	96
tests/kafkatest/tests/core/round_trip_fault_test.py	65
tests/kafkatest/tests/core/security_rolling_upgrade_test.py	108
tests/kafkatest/tests/core/security_test.py	80
tests/kafkatest/tests/core/simple_consumer_shell_test.py	43
tests/kafkatest/tests/core/throttling_test.py	118
tests/kafkatest/tests/core/transactions_test.py	196
tests/kafkatest/tests/core/upgrade_test.py	86
tests/kafkatest/tests/core/zookeeper_security_upgrade_test.py	72
tests/kafkatest/tests/kafka_test.py	16
tests/kafkatest/tests/produce_consume_validate.py	119
tests/kafkatest/tests/streams/__init__.py	1
tests/kafkatest/tests/streams/streams_bounce_test.py	33
tests/kafkatest/tests/streams/streams_broker_bounce_test.py	148
tests/kafkatest/tests/streams/streams_broker_compatibility_test.py	81
tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py	66
tests/kafkatest/tests/streams/streams_eos_test.py	114
tests/kafkatest/tests/streams/streams_shutdown_deadlock_test.py	13
tests/kafkatest/tests/streams/streams_smoke_test.py	40
tests/kafkatest/tests/streams/streams_upgrade_test.py	97
tests/kafkatest/tests/tools/__init__.py	1
tests/kafkatest/tests/tools/kibosh_test.py	50
tests/kafkatest/tests/tools/log4j_appender_test.py	58
tests/kafkatest/tests/tools/replica_verification_test.py	52
tests/kafkatest/tests/tools/trogdor_test.py	66
tests/kafkatest/tests/verifiable_consumer_test.py	58
tests/kafkatest/utils/__init__.py	1
tests/kafkatest/utils/remote_account.py	11
tests/kafkatest/utils/util.py	43
tests/kafkatest/version.py	41
tests/setup.cfg	6
tests/setup.py	33
tests/unit/__init__.py	1
tests/unit/directory_layout/__init__.py	1
tests/unit/directory_layout/check_project_paths.py	40
tests/unit/setup.cfg	4
tests/unit/version/__init__.py	1
tests/unit/version/check_version.py	12
tools/src/test/java/org/apache/kafka/tools/PushHttpMetricsReporterTest.java	260
tools/src/test/java/org/apache/kafka/trogdor/agent/AgentTest.java	265
tools/src/test/java/org/apache/kafka/trogdor/basic/BasicPlatformTest.java	45
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/MiniTrogdorCluster.java	202
tools/src/test/java/org/apache/kafka/trogdor/coordinator/CoordinatorTest.java	259
tools/src/test/java/org/apache/kafka/trogdor/rest/RestExceptionMapperTest.java	67
tools/src/test/java/org/apache/kafka/trogdor/task/SampleTaskController.java	9
tools/src/test/java/org/apache/kafka/trogdor/task/SampleTaskSpec.java	32
tools/src/test/java/org/apache/kafka/trogdor/task/SampleTaskWorker.java	40
tools/src/test/java/org/apache/kafka/trogdor/task/TaskSpecTest.java	31
tools/src/test/java/org/apache/kafka/trogdor/workload/HistogramTest.java	57
tools/src/test/java/org/apache/kafka/trogdor/workload/ThrottleTest.java	42