kafka-clients-2.0.0-test-sources.jar

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

org.apache.kafka:kafka-clients:2.0.0

META-INF/MANIFEST.MF
LICENSE
NOTICE
log4j.properties
serializedData/offsetAndMetadataSerializedfile
serializedData/topicPartitionSerializedfile
org/apache/kafka/clients/admin/AdminClientUnitTestEnv.java
org/apache/kafka/clients/admin/ConfigTest.java
org/apache/kafka/clients/admin/internals/AdminMetadataManagerTest.java
org/apache/kafka/clients/admin/KafkaAdminClientTest.java
org/apache/kafka/clients/admin/MockAdminClient.java
org/apache/kafka/clients/ApiVersionsTest.java
org/apache/kafka/clients/ClientUtilsTest.java
org/apache/kafka/clients/ClusterConnectionStatesTest.java
org/apache/kafka/clients/CommonClientConfigsTest.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/consumer/StickyAssignorTest.java
org/apache/kafka/clients/FetchSessionHandlerTest.java
org/apache/kafka/clients/InFlightRequestsTest.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/ProducerBatchTest.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/internals/TransactionManagerTest.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/RecordMetadataTest.java
org/apache/kafka/clients/producer/RecordSendTest.java
org/apache/kafka/common/acl/AclBindingTest.java
org/apache/kafka/common/acl/AclOperationTest.java
org/apache/kafka/common/acl/AclPermissionTypeTest.java
org/apache/kafka/common/acl/ResourcePatternFilterTest.java
org/apache/kafka/common/acl/ResourcePatternTest.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/config/ConfigResourceTest.java
org/apache/kafka/common/config/ConfigTransformerTest.java
org/apache/kafka/common/config/provider/FileConfigProviderTest.java
org/apache/kafka/common/config/SaslConfigsTest.java
org/apache/kafka/common/header/internals/RecordHeadersTest.java
org/apache/kafka/common/internals/PartitionStatesTest.java
org/apache/kafka/common/internals/TopicTest.java
org/apache/kafka/common/KafkaFutureTest.java
org/apache/kafka/common/memory/GarbageCollectedMemoryPoolTest.java
org/apache/kafka/common/metrics/FakeMetricsReporter.java
org/apache/kafka/common/metrics/JmxReporterTest.java
org/apache/kafka/common/metrics/KafkaMbeanTest.java
org/apache/kafka/common/metrics/MetricsTest.java
org/apache/kafka/common/metrics/SampleMetrics.java
org/apache/kafka/common/metrics/SensorTest.java
org/apache/kafka/common/metrics/stats/FrequenciesTest.java
org/apache/kafka/common/metrics/stats/HistogramTest.java
org/apache/kafka/common/metrics/stats/MeterTest.java
org/apache/kafka/common/network/CertStores.java
org/apache/kafka/common/network/ChannelBuildersTest.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/PlaintextSender.java
org/apache/kafka/common/network/SaslChannelBuilderTest.java
org/apache/kafka/common/network/SelectorTest.java
org/apache/kafka/common/network/SslSelectorTest.java
org/apache/kafka/common/network/SslSender.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/AbstractLegacyRecordBatchTest.java
org/apache/kafka/common/record/BufferSupplierTest.java
org/apache/kafka/common/record/ByteBufferLogInputStreamTest.java
org/apache/kafka/common/record/CompressionTypeTest.java
org/apache/kafka/common/record/ControlRecordTypeTest.java
org/apache/kafka/common/record/DefaultRecordBatchTest.java
org/apache/kafka/common/record/DefaultRecordTest.java
org/apache/kafka/common/record/EndTransactionMarkerTest.java
org/apache/kafka/common/record/FileLogInputStreamTest.java
org/apache/kafka/common/record/FileRecordsTest.java
org/apache/kafka/common/record/KafkaLZ4Test.java
org/apache/kafka/common/record/LazyDownConversionRecordsTest.java
org/apache/kafka/common/record/LegacyRecordTest.java
org/apache/kafka/common/record/MemoryRecordsBuilderTest.java
org/apache/kafka/common/record/MemoryRecordsTest.java
org/apache/kafka/common/record/MultiRecordsSendTest.java
org/apache/kafka/common/record/SimpleLegacyRecordTest.java
org/apache/kafka/common/record/SimpleMemoryRecordsTest.java
org/apache/kafka/common/requests/ApiVersionsResponseTest.java
org/apache/kafka/common/requests/ByteBufferChannel.java
org/apache/kafka/common/requests/CreateAclsRequestTest.java
org/apache/kafka/common/requests/DeleteAclsRequestTest.java
org/apache/kafka/common/requests/DeleteAclsResponseTest.java
org/apache/kafka/common/requests/DescribeAclsRequestTest.java
org/apache/kafka/common/requests/DescribeAclsResponseTest.java
org/apache/kafka/common/requests/LeaderAndIsrResponseTest.java
org/apache/kafka/common/requests/ProduceRequestTest.java
org/apache/kafka/common/requests/RequestContextTest.java
org/apache/kafka/common/requests/RequestHeaderTest.java
org/apache/kafka/common/requests/RequestResponseTest.java
org/apache/kafka/common/requests/StopReplicaResponseTest.java
org/apache/kafka/common/resource/ResourceFilterTest.java
org/apache/kafka/common/resource/ResourceTypeTest.java
org/apache/kafka/common/security/auth/DefaultKafkaPrincipalBuilderTest.java
org/apache/kafka/common/security/auth/KafkaPrincipalTest.java
org/apache/kafka/common/security/authenticator/ClientAuthenticationFailureTest.java
org/apache/kafka/common/security/authenticator/LoginManagerTest.java
org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java
org/apache/kafka/common/security/authenticator/SaslServerAuthenticatorTest.java
org/apache/kafka/common/security/authenticator/TestDigestLoginModule.java
org/apache/kafka/common/security/authenticator/TestJaasConfig.java
org/apache/kafka/common/security/JaasContextTest.java
org/apache/kafka/common/security/kerberos/KerberosNameTest.java
org/apache/kafka/common/security/kerberos/KerberosRuleTest.java
org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshConfigTest.java
org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshingLoginTest.java
org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerClientInitialResponseTest.java
org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServerTest.java
org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerScopeUtilsTest.java
org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredJwsTest.java
org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredLoginCallbackHandlerTest.java
org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredValidatorCallbackHandlerTest.java
org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerValidationUtilsTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModuleTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenCallbackTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallbackTest.java
#内容未全部加载，请点击展开加载全部代码(NowJava.com)