kafka-clients-2.2.0-test-sources.jar

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

org.apache.kafka:kafka-clients:2.2.0

META-INF/MANIFEST.MF
LICENSE
NOTICE
serializedData/offsetAndMetadataBeforeLeaderEpoch
serializedData/topicPartitionSerializedfile
serializedData/offsetAndMetadataWithLeaderEpoch
log4j.properties
org/apache/kafka/common/message/RequestHeaderData.java
org/apache/kafka/common/message/OffsetFetchResponseData.java
org/apache/kafka/common/message/ControlledShutdownRequestData.java
org/apache/kafka/common/message/ApiVersionsRequestData.java
org/apache/kafka/common/message/DeleteAclsRequestData.java
org/apache/kafka/common/message/WriteTxnMarkersRequestData.java
org/apache/kafka/common/message/CreateAclsResponseData.java
org/apache/kafka/common/message/ListOffsetRequestData.java
org/apache/kafka/common/message/ListGroupsResponseData.java
org/apache/kafka/common/message/SyncGroupResponseData.java
org/apache/kafka/common/message/DescribeLogDirsResponseData.java
org/apache/kafka/common/message/SaslHandshakeRequestData.java
org/apache/kafka/common/message/DescribeGroupsResponseData.java
org/apache/kafka/common/message/ListGroupsRequestData.java
org/apache/kafka/common/message/FetchResponseData.java
org/apache/kafka/common/message/ElectPreferredLeadersResponseData.java
org/apache/kafka/common/message/RenewDelegationTokenRequestData.java
org/apache/kafka/common/message/OffsetCommitResponseData.java
org/apache/kafka/common/message/AddOffsetsToTxnRequestData.java
org/apache/kafka/common/message/MetadataRequestData.java
org/apache/kafka/common/message/EndTxnRequestData.java
org/apache/kafka/common/message/CreateTopicsResponseData.java
org/apache/kafka/common/message/DescribeConfigsResponseData.java
org/apache/kafka/common/message/CreateAclsRequestData.java
org/apache/kafka/common/message/CreatePartitionsResponseData.java
org/apache/kafka/common/message/ControlledShutdownResponseData.java
org/apache/kafka/common/message/CreateDelegationTokenRequestData.java
org/apache/kafka/common/message/DescribeAclsResponseData.java
org/apache/kafka/common/message/AlterConfigsRequestData.java
org/apache/kafka/common/message/SaslHandshakeResponseData.java
org/apache/kafka/common/message/CreateDelegationTokenResponseData.java
org/apache/kafka/common/message/DeleteGroupsResponseData.java
org/apache/kafka/common/message/ResponseHeaderData.java
org/apache/kafka/common/message/ListOffsetResponseData.java
org/apache/kafka/common/message/FindCoordinatorResponseData.java
org/apache/kafka/common/message/LeaveGroupRequestData.java
org/apache/kafka/common/message/SyncGroupRequestData.java
org/apache/kafka/common/message/LeaderAndIsrRequestData.java
org/apache/kafka/common/message/DeleteTopicsResponseData.java
org/apache/kafka/common/message/MetadataResponseData.java
org/apache/kafka/common/message/UpdateMetadataResponseData.java
org/apache/kafka/common/message/OffsetForLeaderEpochRequestData.java
org/apache/kafka/common/message/OffsetCommitRequestData.java
org/apache/kafka/common/message/CreateTopicsRequestData.java
org/apache/kafka/common/message/StopReplicaRequestData.java
org/apache/kafka/common/message/CreatePartitionsRequestData.java
org/apache/kafka/common/message/SaslAuthenticateResponseData.java
org/apache/kafka/common/message/FindCoordinatorRequestData.java
org/apache/kafka/common/message/HeartbeatRequestData.java
org/apache/kafka/common/message/DeleteAclsResponseData.java
org/apache/kafka/common/message/ProduceResponseData.java
org/apache/kafka/common/message/SaslAuthenticateRequestData.java
org/apache/kafka/common/message/WriteTxnMarkersResponseData.java
org/apache/kafka/common/message/StopReplicaResponseData.java
org/apache/kafka/common/message/DeleteTopicsRequestData.java
org/apache/kafka/common/message/TxnOffsetCommitRequestData.java
org/apache/kafka/common/message/TxnOffsetCommitResponseData.java
org/apache/kafka/common/message/ExpireDelegationTokenResponseData.java
org/apache/kafka/common/message/HeartbeatResponseData.java
org/apache/kafka/common/message/OffsetFetchRequestData.java
org/apache/kafka/common/message/FetchRequestData.java
org/apache/kafka/common/message/DeleteGroupsRequestData.java
org/apache/kafka/common/message/DescribeConfigsRequestData.java
org/apache/kafka/common/message/ExpireDelegationTokenRequestData.java
org/apache/kafka/common/message/DeleteRecordsResponseData.java
org/apache/kafka/common/message/AlterReplicaLogDirsResponseData.java
org/apache/kafka/common/message/LeaderAndIsrResponseData.java
org/apache/kafka/common/message/ProduceRequestData.java
org/apache/kafka/common/message/DescribeLogDirsRequestData.java
org/apache/kafka/common/message/JoinGroupRequestData.java
org/apache/kafka/common/message/DescribeDelegationTokenRequestData.java
org/apache/kafka/common/message/AddOffsetsToTxnResponseData.java
org/apache/kafka/common/message/EndTxnResponseData.java
org/apache/kafka/common/message/UpdateMetadataRequestData.java
org/apache/kafka/common/message/DescribeAclsRequestData.java
org/apache/kafka/common/message/LeaveGroupResponseData.java
org/apache/kafka/common/message/AlterReplicaLogDirsRequestData.java
org/apache/kafka/common/message/AlterConfigsResponseData.java
org/apache/kafka/common/message/DescribeDelegationTokenResponseData.java
org/apache/kafka/common/message/RenewDelegationTokenResponseData.java
org/apache/kafka/common/message/ApiVersionsResponseData.java
org/apache/kafka/common/message/ApiMessageFactory.java
org/apache/kafka/common/message/DeleteRecordsRequestData.java
org/apache/kafka/common/message/DescribeGroupsRequestData.java
org/apache/kafka/common/message/AddPartitionsToTxnResponseData.java
org/apache/kafka/common/message/OffsetForLeaderEpochResponseData.java
org/apache/kafka/common/message/ElectPreferredLeadersRequestData.java
org/apache/kafka/common/message/JoinGroupResponseData.java
org/apache/kafka/common/message/InitProducerIdResponseData.java
org/apache/kafka/common/message/AddPartitionsToTxnRequestData.java
org/apache/kafka/common/message/InitProducerIdRequestData.java
org/apache/kafka/clients/ClientUtilsTest.java
org/apache/kafka/clients/producer/RecordSendTest.java
org/apache/kafka/clients/producer/ProducerRecordTest.java
org/apache/kafka/clients/producer/MockProducerTest.java
org/apache/kafka/clients/producer/RecordMetadataTest.java
org/apache/kafka/clients/producer/KafkaProducerTest.java
org/apache/kafka/clients/producer/internals/TransactionManagerTest.java
org/apache/kafka/clients/producer/internals/DefaultPartitionerTest.java
org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java
org/apache/kafka/clients/producer/internals/SenderTest.java
org/apache/kafka/clients/producer/internals/FutureRecordMetadataTest.java
org/apache/kafka/clients/producer/internals/ProducerBatchTest.java
org/apache/kafka/clients/producer/internals/BufferPoolTest.java
org/apache/kafka/clients/producer/internals/ProducerInterceptorsTest.java
org/apache/kafka/clients/MockClient.java
org/apache/kafka/clients/NodeApiVersionsTest.java
org/apache/kafka/clients/admin/KafkaAdminClientTest.java
org/apache/kafka/clients/admin/AdminClientUnitTestEnv.java
org/apache/kafka/clients/admin/internals/AdminMetadataManagerTest.java
org/apache/kafka/clients/admin/ConfigTest.java
org/apache/kafka/clients/admin/MockAdminClient.java
org/apache/kafka/clients/ClusterConnectionStatesTest.java
org/apache/kafka/clients/NetworkClientTest.java
org/apache/kafka/clients/InFlightRequestsTest.java
org/apache/kafka/clients/CommonClientConfigsTest.java
org/apache/kafka/clients/consumer/RangeAssignorTest.java
org/apache/kafka/clients/consumer/MockConsumerTest.java
org/apache/kafka/clients/consumer/RoundRobinAssignorTest.java
org/apache/kafka/clients/consumer/ConsumerRecordsTest.java
org/apache/kafka/clients/consumer/KafkaConsumerTest.java
org/apache/kafka/clients/consumer/OffsetAndMetadataTest.java
org/apache/kafka/clients/consumer/ConsumerRecordTest.java
org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java
org/apache/kafka/clients/consumer/internals/RequestFutureTest.java
org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java
org/apache/kafka/clients/consumer/internals/ConsumerNetworkClientTest.java
org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java
org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java
org/apache/kafka/clients/consumer/internals/ConsumerInterceptorsTest.java
org/apache/kafka/clients/consumer/internals/HeartbeatTest.java
org/apache/kafka/clients/consumer/internals/FetcherTest.java
org/apache/kafka/clients/consumer/internals/MockPartitionAssignor.java
org/apache/kafka/clients/consumer/ConsumerConfigTest.java
org/apache/kafka/clients/consumer/StickyAssignorTest.java
org/apache/kafka/clients/FetchSessionHandlerTest.java
org/apache/kafka/clients/ApiVersionsTest.java
org/apache/kafka/clients/MetadataTest.java
org/apache/kafka/test/TestCondition.java
org/apache/kafka/test/TestUtils.java
org/apache/kafka/test/DelayedReceive.java
org/apache/kafka/test/MockMetricsReporter.java
org/apache/kafka/test/Microbenchmarks.java
org/apache/kafka/test/TestSslUtils.java
org/apache/kafka/test/MockSelector.java
org/apache/kafka/test/MockClusterResourceListener.java
org/apache/kafka/test/MetricsBench.java
org/apache/kafka/test/MockConsumerInterceptor.java
org/apache/kafka/test/MockDeserializer.java
org/apache/kafka/test/MockPartitioner.java
org/apache/kafka/test/MockProducerInterceptor.java
org/apache/kafka/test/IntegrationTest.java
org/apache/kafka/test/MockSerializer.java
org/apache/kafka/common/KafkaFutureTest.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/FakeMetricsReporter.java
org/apache/kafka/common/metrics/KafkaMbeanTest.java
org/apache/kafka/common/metrics/SampleMetrics.java
org/apache/kafka/common/metrics/stats/HistogramTest.java
org/apache/kafka/common/metrics/stats/MeterTest.java
org/apache/kafka/common/metrics/stats/FrequenciesTest.java
org/apache/kafka/common/record/DefaultRecordBatchTest.java
org/apache/kafka/common/record/CompressionTypeTest.java
org/apache/kafka/common/record/FileRecordsTest.java
org/apache/kafka/common/record/MemoryRecordsTest.java
org/apache/kafka/common/record/KafkaLZ4Test.java
org/apache/kafka/common/record/LazyDownConversionRecordsTest.java
org/apache/kafka/common/record/AbstractLegacyRecordBatchTest.java
org/apache/kafka/common/record/ControlRecordTypeTest.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/SimpleLegacyRecordTest.java
org/apache/kafka/common/record/ByteBufferLogInputStreamTest.java
org/apache/kafka/common/record/BufferSupplierTest.java
org/apache/kafka/common/record/SimpleMemoryRecordsTest.java
org/apache/kafka/common/record/LegacyRecordTest.java
org/apache/kafka/common/record/MultiRecordsSendTest.java
org/apache/kafka/common/record/MemoryRecordsBuilderTest.java
org/apache/kafka/common/memory/GarbageCollectedMemoryPoolTest.java
org/apache/kafka/common/cache/LRUCacheTest.java
org/apache/kafka/common/config/SaslConfigsTest.java
org/apache/kafka/common/config/AbstractConfigTest.java
org/apache/kafka/common/config/provider/FileConfigProviderTest.java
org/apache/kafka/common/config/ConfigDefTest.java
org/apache/kafka/common/config/ConfigTransformerTest.java
org/apache/kafka/common/config/ConfigResourceTest.java
org/apache/kafka/common/security/kerberos/KerberosNameTest.java
org/apache/kafka/common/security/kerberos/KerberosRuleTest.java
org/apache/kafka/common/security/SaslExtensionsTest.java
org/apache/kafka/common/security/ssl/SslPrincipalMapperTest.java
org/apache/kafka/common/security/ssl/SslFactoryTest.java
org/apache/kafka/common/security/auth/DefaultKafkaPrincipalBuilderTest.java
org/apache/kafka/common/security/auth/KafkaPrincipalTest.java
org/apache/kafka/common/security/plain/internals/PlainSaslServerTest.java
org/apache/kafka/common/security/JaasContextTest.java
org/apache/kafka/common/security/TestSecurityConfig.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerExtensionsValidatorCallbackTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallbackTest.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/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/internals/unsecured/OAuthBearerScopeUtilsTest.java
org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientTest.java
org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshingLoginTest.java
org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshConfigTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModuleTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenCallbackTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerSaslClienCallbackHandlerTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenMock.java
org/apache/kafka/common/security/scram/internals/ScramFormatterTest.java
org/apache/kafka/common/security/scram/internals/ScramSaslServerTest.java
org/apache/kafka/common/security/scram/internals/ScramCredentialUtilsTest.java
org/apache/kafka/common/security/scram/internals/ScramMessagesTest.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/authenticator/SaslServerAuthenticatorTest.java
org/apache/kafka/common/security/authenticator/SaslAuthenticatorFailureDelayTest.java
org/apache/kafka/common/security/authenticator/ClientAuthenticationFailureTest.java
org/apache/kafka/common/security/authenticator/LoginManagerTest.java
#内容未全部加载，请点击展开加载全部代码(NowJava.com)