kafka-clients-1.1.1-test-sources.jar

<dependency>
	<groupId>org.apache.kafka</groupId>
	<artifactId>kafka-clients</artifactId>
	<version>1.1.1</version>
</dependency>

org.apache.kafka:kafka-clients:1.1.1

META-INF/MANIFEST.MF
LICENSE
NOTICE
serializedData/topicPartitionSerializedfile
serializedData/offsetAndMetadataSerializedfile
log4j.properties
org/apache/kafka/test/TestCondition.java
org/apache/kafka/test/MockMetricsReporter.java
org/apache/kafka/test/DelayedReceive.java
org/apache/kafka/test/MockConsumerInterceptor.java
org/apache/kafka/test/MockProducerInterceptor.java
org/apache/kafka/test/TestSslUtils.java
org/apache/kafka/test/MockPartitioner.java
org/apache/kafka/test/MockDeserializer.java
org/apache/kafka/test/IntegrationTest.java
org/apache/kafka/test/Microbenchmarks.java
org/apache/kafka/test/TestUtils.java
org/apache/kafka/test/MockSerializer.java
org/apache/kafka/test/MockSelector.java
org/apache/kafka/test/MetricsBench.java
org/apache/kafka/test/MockClusterResourceListener.java
org/apache/kafka/common/KafkaFutureTest.java
org/apache/kafka/common/memory/GarbageCollectedMemoryPoolTest.java
org/apache/kafka/common/PartitionInfoTest.java
org/apache/kafka/common/requests/RequestHeaderTest.java
org/apache/kafka/common/requests/ProduceRequestTest.java
org/apache/kafka/common/requests/RequestContextTest.java
org/apache/kafka/common/requests/LeaderAndIsrResponseTest.java
org/apache/kafka/common/requests/StopReplicaResponseTest.java
org/apache/kafka/common/requests/RequestResponseTest.java
org/apache/kafka/common/requests/ApiVersionsResponseTest.java
org/apache/kafka/common/requests/ByteBufferChannel.java
org/apache/kafka/common/protocol/ErrorsTest.java
org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java
org/apache/kafka/common/protocol/ApiKeysTest.java
org/apache/kafka/common/protocol/ProtoUtilsTest.java
org/apache/kafka/common/ClusterTest.java
org/apache/kafka/common/record/FileRecordsTest.java
org/apache/kafka/common/record/CompressionTypeTest.java
org/apache/kafka/common/record/FileLogInputStreamTest.java
org/apache/kafka/common/record/MemoryRecordsBuilderTest.java
org/apache/kafka/common/record/DefaultRecordBatchTest.java
org/apache/kafka/common/record/KafkaLZ4Test.java
org/apache/kafka/common/record/ControlRecordTypeTest.java
org/apache/kafka/common/record/EndTransactionMarkerTest.java
org/apache/kafka/common/record/MemoryRecordsTest.java
org/apache/kafka/common/record/SimpleLegacyRecordTest.java
org/apache/kafka/common/record/AbstractLegacyRecordBatchTest.java
org/apache/kafka/common/record/LegacyRecordTest.java
org/apache/kafka/common/record/ByteBufferLogInputStreamTest.java
org/apache/kafka/common/record/DefaultRecordTest.java
org/apache/kafka/common/record/SimpleMemoryRecordsTest.java
org/apache/kafka/common/security/kerberos/KerberosNameTest.java
org/apache/kafka/common/security/authenticator/ClientAuthenticationFailureTest.java
org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java
org/apache/kafka/common/security/authenticator/TestJaasConfig.java
org/apache/kafka/common/security/authenticator/SaslServerAuthenticatorTest.java
org/apache/kafka/common/security/authenticator/LoginManagerTest.java
org/apache/kafka/common/security/authenticator/TestDigestLoginModule.java
org/apache/kafka/common/security/plain/PlainSaslServerTest.java
org/apache/kafka/common/security/scram/ScramCredentialUtilsTest.java
org/apache/kafka/common/security/scram/ScramSaslServerTest.java
org/apache/kafka/common/security/scram/ScramMessagesTest.java
org/apache/kafka/common/security/scram/ScramFormatterTest.java
org/apache/kafka/common/security/auth/DefaultKafkaPrincipalBuilderTest.java
org/apache/kafka/common/security/auth/KafkaPrincipalTest.java
org/apache/kafka/common/security/JaasContextTest.java
org/apache/kafka/common/security/TestSecurityConfig.java
org/apache/kafka/common/security/ssl/SslFactoryTest.java
org/apache/kafka/common/header/internals/RecordHeadersTest.java
org/apache/kafka/common/internals/TopicTest.java
org/apache/kafka/common/internals/PartitionStatesTest.java
org/apache/kafka/common/SerializeCompatibilityTopicPartitionTest.java
org/apache/kafka/common/acl/AclBindingTest.java
org/apache/kafka/common/acl/AclPermissionTypeTest.java
org/apache/kafka/common/acl/AclOperationTest.java
org/apache/kafka/common/serialization/SerializationTest.java
org/apache/kafka/common/cache/LRUCacheTest.java
org/apache/kafka/common/metrics/SensorTest.java
org/apache/kafka/common/metrics/KafkaMbeanTest.java
org/apache/kafka/common/metrics/SampleMetrics.java
org/apache/kafka/common/metrics/MetricsTest.java
org/apache/kafka/common/metrics/stats/MeterTest.java
org/apache/kafka/common/metrics/stats/HistogramTest.java
org/apache/kafka/common/metrics/stats/FrequenciesTest.java
org/apache/kafka/common/metrics/FakeMetricsReporter.java
org/apache/kafka/common/metrics/JmxReporterTest.java
org/apache/kafka/common/config/AbstractConfigTest.java
org/apache/kafka/common/config/ConfigDefTest.java
org/apache/kafka/common/resource/ResourceTypeTest.java
org/apache/kafka/common/utils/MockTime.java
org/apache/kafka/common/utils/Crc32CTest.java
org/apache/kafka/common/utils/Crc32Test.java
org/apache/kafka/common/utils/ByteUtilsTest.java
org/apache/kafka/common/utils/LoggingSignalHandlerTest.java
org/apache/kafka/common/utils/ImplicitLinkedHashSetTest.java
org/apache/kafka/common/utils/MockScheduler.java
org/apache/kafka/common/utils/ShellTest.java
org/apache/kafka/common/utils/SecurityUtilsTest.java
org/apache/kafka/common/utils/AbstractIteratorTest.java
org/apache/kafka/common/utils/ChecksumsTest.java
org/apache/kafka/common/utils/JavaTest.java
org/apache/kafka/common/utils/SanitizerTest.java
org/apache/kafka/common/utils/ByteBufferOutputStreamTest.java
org/apache/kafka/common/utils/MappedByteBuffersTest.java
org/apache/kafka/common/utils/Base64Test.java
org/apache/kafka/common/utils/UtilsTest.java
org/apache/kafka/common/utils/Serializer.java
org/apache/kafka/common/utils/MockTimeTest.java
org/apache/kafka/common/network/SslSelectorTest.java
org/apache/kafka/common/network/SslSender.java
org/apache/kafka/common/network/ChannelBuildersTest.java
org/apache/kafka/common/network/CertStores.java
org/apache/kafka/common/network/NioEchoServer.java
org/apache/kafka/common/network/NetworkTestUtils.java
org/apache/kafka/common/network/SslTransportLayerTest.java
org/apache/kafka/common/network/PlaintextSender.java
org/apache/kafka/common/network/MultiSendTest.java
org/apache/kafka/common/network/EchoServer.java
org/apache/kafka/common/network/SaslChannelBuilderTest.java
org/apache/kafka/common/network/SelectorTest.java
org/apache/kafka/clients/NetworkClientTest.java
org/apache/kafka/clients/consumer/ConsumerRecordTest.java
org/apache/kafka/clients/consumer/SerializeCompatibilityOffsetAndMetadataTest.java
org/apache/kafka/clients/consumer/KafkaConsumerTest.java
org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java
org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java
org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java
org/apache/kafka/clients/consumer/internals/MockPartitionAssignor.java
org/apache/kafka/clients/consumer/internals/RequestFutureTest.java
org/apache/kafka/clients/consumer/internals/FetcherTest.java
org/apache/kafka/clients/consumer/internals/ConsumerNetworkClientTest.java
org/apache/kafka/clients/consumer/internals/ConsumerInterceptorsTest.java
org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java
#内容未全部加载，请点击展开加载全部代码(NowJava.com)