kafka-clients-0.10.2.0-test-sources.jar

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

org.apache.kafka:kafka-clients:0.10.2.0

META-INF/MANIFEST.MF
LICENSE
NOTICE
log4j.properties
serializedData/offsetAndMetadataSerializedfile
serializedData/topicPartitionSerializedfile
org/apache/kafka/clients/ClientUtilsTest.java
org/apache/kafka/clients/consumer/ConsumerConfigTest.java
org/apache/kafka/clients/consumer/ConsumerRecordsTest.java
org/apache/kafka/clients/consumer/ConsumerRecordTest.java
org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java
org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java
org/apache/kafka/clients/consumer/internals/ConsumerInterceptorsTest.java
org/apache/kafka/clients/consumer/internals/ConsumerNetworkClientTest.java
org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java
org/apache/kafka/clients/consumer/internals/FetcherTest.java
org/apache/kafka/clients/consumer/internals/HeartbeatTest.java
org/apache/kafka/clients/consumer/internals/MockPartitionAssignor.java
org/apache/kafka/clients/consumer/internals/RequestFutureTest.java
org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java
org/apache/kafka/clients/consumer/KafkaConsumerTest.java
org/apache/kafka/clients/consumer/MockConsumerTest.java
org/apache/kafka/clients/consumer/RangeAssignorTest.java
org/apache/kafka/clients/consumer/RoundRobinAssignorTest.java
org/apache/kafka/clients/consumer/SerializeCompatibilityOffsetAndMetadataTest.java
org/apache/kafka/clients/MetadataTest.java
org/apache/kafka/clients/MockClient.java
org/apache/kafka/clients/NetworkClientTest.java
org/apache/kafka/clients/NodeApiVersionsTest.java
org/apache/kafka/clients/producer/internals/BufferPoolTest.java
org/apache/kafka/clients/producer/internals/DefaultPartitionerTest.java
org/apache/kafka/clients/producer/internals/ProducerInterceptorsTest.java
org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java
org/apache/kafka/clients/producer/internals/SenderTest.java
org/apache/kafka/clients/producer/KafkaProducerTest.java
org/apache/kafka/clients/producer/MockProducerTest.java
org/apache/kafka/clients/producer/ProducerRecordTest.java
org/apache/kafka/clients/producer/RecordSendTest.java
org/apache/kafka/common/cache/LRUCacheTest.java
org/apache/kafka/common/ClusterTest.java
org/apache/kafka/common/config/AbstractConfigTest.java
org/apache/kafka/common/config/ConfigDefTest.java
org/apache/kafka/common/internals/PartitionStatesTest.java
org/apache/kafka/common/metrics/FakeMetricsReporter.java
org/apache/kafka/common/metrics/JmxReporterTest.java
org/apache/kafka/common/metrics/MetricsTest.java
org/apache/kafka/common/metrics/SensorTest.java
org/apache/kafka/common/metrics/stats/HistogramTest.java
org/apache/kafka/common/network/CertStores.java
org/apache/kafka/common/network/EchoServer.java
org/apache/kafka/common/network/NetworkTestUtils.java
org/apache/kafka/common/network/NioEchoServer.java
org/apache/kafka/common/network/SelectorTest.java
org/apache/kafka/common/network/SslSelectorTest.java
org/apache/kafka/common/network/SslTransportLayerTest.java
org/apache/kafka/common/PartitionInfoTest.java
org/apache/kafka/common/protocol/ApiKeysTest.java
org/apache/kafka/common/protocol/ErrorsTest.java
org/apache/kafka/common/protocol/ProtoUtilsTest.java
org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java
org/apache/kafka/common/record/ByteBufferLogInputStreamTest.java
org/apache/kafka/common/record/FileRecordsTest.java
org/apache/kafka/common/record/KafkaLZ4Test.java
org/apache/kafka/common/record/MemoryRecordsBuilderTest.java
org/apache/kafka/common/record/MemoryRecordsTest.java
org/apache/kafka/common/record/RecordTest.java
org/apache/kafka/common/record/SimpleRecordTest.java
org/apache/kafka/common/record/TimestampTypeTest.java
org/apache/kafka/common/requests/RequestResponseTest.java
org/apache/kafka/common/security/auth/KafkaPrincipalTest.java
org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java
org/apache/kafka/common/security/authenticator/TestDigestLoginModule.java
org/apache/kafka/common/security/authenticator/TestJaasConfig.java
org/apache/kafka/common/security/JaasUtilsTest.java
org/apache/kafka/common/security/kerberos/KerberosNameTest.java
org/apache/kafka/common/security/scram/ScramCredentialUtilsTest.java
org/apache/kafka/common/security/scram/ScramFormatterTest.java
org/apache/kafka/common/security/scram/ScramMessagesTest.java
#内容未全部加载，请点击展开加载全部代码(NowJava.com)