登录注册

Jar文件详情内容

kafka-clients-2.2.1-test.jar

所在目录：/org/apache/kafka/kafka-clients/2.2.1 查看kafka-clients所有版本文件

组织ID:	org.apache.kafka
项目ID:	kafka-clients
版本:	2.2.1
最后修改时间:	2019-06-06 19:28:31
包类型:	jar
大小:	1.57MB

Maven引入代码:	`<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.2.1</version> </dependency>`
Gradle引入代码:	`org.apache.kafka:kafka-clients:2.2.1`
下载Jar包:	kafka-clients-2.2.1-test.jar
Jar包内容:	展开复制 META-INF/MANIFEST.MF LICENSE NOTICE org.apache.kafka.clients.InFlightRequestsTest.class org.apache.kafka.clients.CommonClientConfigsTest$TestConfig.class org.apache.kafka.clients.FetchSessionHandlerTest$ReqEntry.class org.apache.kafka.clients.NetworkClientTest$2.class org.apache.kafka.clients.MetadataTest$1.class org.apache.kafka.clients.FetchSessionHandlerTest$RespEntry.class org.apache.kafka.clients.ClientUtilsTest.class org.apache.kafka.clients.NetworkClientTest.class org.apache.kafka.clients.MockClient$MetadataUpdate.class org.apache.kafka.clients.MetadataTest$3.class org.apache.kafka.clients.NetworkClientTest$TestCallbackHandler.class org.apache.kafka.clients.NodeApiVersionsTest.class org.apache.kafka.clients.FetchSessionHandlerTest$1.class org.apache.kafka.clients.FetchSessionHandlerTest.class org.apache.kafka.clients.consumer.ConsumerConfigTest.class org.apache.kafka.clients.consumer.RoundRobinAssignorTest.class org.apache.kafka.clients.consumer.KafkaConsumerTest$6.class org.apache.kafka.clients.consumer.ConsumerRecordTest.class org.apache.kafka.clients.consumer.KafkaConsumerTest$7.class org.apache.kafka.clients.consumer.KafkaConsumerTest$1.class org.apache.kafka.clients.consumer.KafkaConsumerTest$4.class org.apache.kafka.clients.consumer.MockConsumerTest.class org.apache.kafka.clients.consumer.ConsumerRecordsTest.class org.apache.kafka.clients.consumer.KafkaConsumerTest$10.class org.apache.kafka.clients.consumer.KafkaConsumerTest$8.class org.apache.kafka.clients.consumer.KafkaConsumerTest$FetchInfo.class org.apache.kafka.clients.consumer.RangeAssignorTest.class org.apache.kafka.clients.consumer.KafkaConsumerTest$2.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$28.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$21.class org.apache.kafka.clients.consumer.internals.ConsumerProtocolTest.class org.apache.kafka.clients.consumer.internals.FetcherTest$7.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$7.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$6.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$3.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$19.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$10.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$8.class org.apache.kafka.clients.consumer.internals.ConsumerInterceptorsTest.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$2.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClientTest.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$4.class org.apache.kafka.clients.consumer.internals.RequestFutureTest$2.class org.apache.kafka.clients.consumer.internals.FetcherTest$4.class org.apache.kafka.clients.consumer.internals.FetcherTest$6$1.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$10.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$11.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$6.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$2.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$12.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$16.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$9.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$11.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$14.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$3.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClientTest$1.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$18.class org.apache.kafka.clients.consumer.internals.FetcherTest$6.class org.apache.kafka.clients.consumer.internals.FetcherTest$5.class org.apache.kafka.clients.consumer.internals.FetcherTest$1.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$13.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$24.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClientTest$2.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$MockRebalanceListener.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$8.class org.apache.kafka.clients.consumer.internals.MockPartitionAssignor.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$4.class org.apache.kafka.clients.consumer.internals.RequestFutureTest$MockRequestFutureListener.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$15.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$9.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$1.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$23.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$26.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$12.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$1.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$7.class org.apache.kafka.clients.consumer.internals.FetcherTest$2.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$5.class org.apache.kafka.clients.consumer.internals.FetcherTest$8.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$27.class org.apache.kafka.clients.consumer.internals.HeartbeatTest.class org.apache.kafka.clients.consumer.internals.FetcherTest.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClientTest$4.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClientTest$3.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$DummyCoordinator.class org.apache.kafka.clients.consumer.internals.FetcherTest$3.class org.apache.kafka.clients.consumer.internals.SubscriptionStateTest$1.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$5.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$22.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$25.class org.apache.kafka.clients.consumer.internals.ConsumerInterceptorsTest$FilterConsumerInterceptor.class org.apache.kafka.clients.consumer.internals.SubscriptionStateTest$MockRebalanceListener.class org.apache.kafka.clients.consumer.internals.RequestFutureTest$1.class org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest$13.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$20.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest.class org.apache.kafka.clients.consumer.internals.RequestFutureTest.class org.apache.kafka.clients.consumer.internals.SubscriptionStateTest.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$17.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinatorTest$MockCommitCallback.class org.apache.kafka.clients.consumer.KafkaConsumerTest$9.class org.apache.kafka.clients.consumer.KafkaConsumerTest.class org.apache.kafka.clients.consumer.KafkaConsumerTest$5.class org.apache.kafka.clients.consumer.KafkaConsumerTest$11.class org.apache.kafka.clients.consumer.KafkaConsumerTest$3.class org.apache.kafka.clients.consumer.OffsetAndMetadataTest.class org.apache.kafka.clients.consumer.StickyAssignorTest.class org.apache.kafka.clients.MockClient$DefaultMockMetadataUpdater.class org.apache.kafka.clients.admin.KafkaAdminClientTest.class org.apache.kafka.clients.admin.AdminClientUnitTestEnv$1.class org.apache.kafka.clients.admin.MockAdminClient$TopicMetadata.class org.apache.kafka.clients.admin.ConfigTest.class org.apache.kafka.clients.admin.KafkaAdminClientTest$FailureInjectingTimeoutProcessorFactory.class org.apache.kafka.clients.admin.AdminClientUnitTestEnv.class org.apache.kafka.clients.admin.internals.AdminMetadataManagerTest.class org.apache.kafka.clients.admin.MockAdminClient.class org.apache.kafka.clients.admin.KafkaAdminClientTest$FailureInjectingTimeoutProcessorFactory$FailureInjectingTimeoutProcessor.class org.apache.kafka.clients.admin.KafkaAdminClientTest$1.class org.apache.kafka.clients.admin.KafkaAdminClientTest$2.class org.apache.kafka.clients.ClusterConnectionStatesTest.class org.apache.kafka.clients.MockClient$MockMetadataUpdater.class org.apache.kafka.clients.MockClient$1.class org.apache.kafka.clients.MockClient$ConnectionState$State.class org.apache.kafka.clients.NetworkClientTest$1.class org.apache.kafka.clients.MockClient$3.class org.apache.kafka.clients.producer.MockProducerTest$1.class org.apache.kafka.clients.producer.RecordSendTest$1.class org.apache.kafka.clients.producer.KafkaProducerTest.class org.apache.kafka.clients.producer.MockProducerTest$9.class org.apache.kafka.clients.producer.RecordSendTest.class org.apache.kafka.clients.producer.MockProducerTest$2.class org.apache.kafka.clients.producer.KafkaProducerTest$1.class org.apache.kafka.clients.producer.KafkaProducerTest$4.class org.apache.kafka.clients.producer.MockProducerTest.class org.apache.kafka.clients.producer.MockProducerTest$8.class org.apache.kafka.clients.producer.MockProducerTest$5.class org.apache.kafka.clients.producer.RecordMetadataTest.class org.apache.kafka.clients.producer.internals.SenderTest$3.class org.apache.kafka.clients.producer.internals.BufferPoolTest$4.class org.apache.kafka.clients.producer.internals.BufferPoolTest.class org.apache.kafka.clients.producer.internals.RecordAccumulatorTest$3.class org.apache.kafka.clients.producer.internals.BufferPoolTest$2.class org.apache.kafka.clients.producer.internals.ProducerBatchTest$1.class org.apache.kafka.clients.producer.internals.SenderTest$MatchingBufferPool.class org.apache.kafka.clients.producer.internals.ProducerBatchTest$MockCallback.class org.apache.kafka.clients.producer.internals.SenderTest$11.class org.apache.kafka.clients.producer.internals.SenderTest$1.class org.apache.kafka.clients.producer.internals.RecordAccumulatorTest$2TestCallback.class org.apache.kafka.clients.producer.internals.ProducerBatchTest.class org.apache.kafka.clients.producer.internals.BufferPoolTest$StressTestThread.class org.apache.kafka.clients.producer.internals.SenderTest.class org.apache.kafka.clients.producer.internals.DefaultPartitionerTest.class org.apache.kafka.clients.producer.internals.SenderTest$4.class org.apache.kafka.clients.producer.internals.RecordAccumulatorTest$BatchDrainedResult.class org.apache.kafka.clients.producer.internals.SenderTest$10.class org.apache.kafka.clients.producer.internals.SenderTest$8.class org.apache.kafka.clients.producer.internals.TransactionManagerTest.class org.apache.kafka.clients.producer.internals.FutureRecordMetadataTest.class org.apache.kafka.clients.producer.internals.BufferPoolTest$BufferPoolAllocator.class org.apache.kafka.clients.producer.internals.SenderTest$13.class org.apache.kafka.clients.producer.internals.SenderTest$12.class org.apache.kafka.clients.producer.internals.SenderTest$9.class org.apache.kafka.clients.producer.internals.RecordAccumulatorTest$1TestCallback.class org.apache.kafka.clients.producer.internals.SenderTest$6.class org.apache.kafka.clients.producer.internals.BufferPoolTest$3.class org.apache.kafka.clients.producer.internals.SenderTest$7.class org.apache.kafka.clients.producer.internals.SenderTest$5.class org.apache.kafka.clients.producer.internals.ProducerInterceptorsTest.class org.apache.kafka.clients.producer.internals.ProducerInterceptorsTest$AppendProducerInterceptor.class org.apache.kafka.clients.producer.internals.SenderTest$2.class org.apache.kafka.clients.producer.internals.RecordAccumulatorTest.class org.apache.kafka.clients.producer.internals.BufferPoolTest$5.class org.apache.kafka.clients.producer.internals.RecordAccumulatorTest$2.class org.apache.kafka.clients.producer.internals.SenderTest$OffsetAndError.class org.apache.kafka.clients.producer.internals.RecordAccumulatorTest$1.class org.apache.kafka.clients.producer.internals.BufferPoolTest$1.class org.apache.kafka.clients.producer.internals.SenderTest$14.class org.apache.kafka.clients.producer.MockProducerTest$3.class org.apache.kafka.clients.producer.MockProducerTest$4.class org.apache.kafka.clients.producer.KafkaProducerTest$3.class org.apache.kafka.clients.producer.MockProducerTest$6.class org.apache.kafka.clients.producer.KafkaProducerTest$2.class org.apache.kafka.clients.producer.MockProducerTest$7.class org.apache.kafka.clients.producer.ProducerRecordTest.class org.apache.kafka.clients.MockClient$FutureResponse.class org.apache.kafka.clients.MetadataTest$2.class org.apache.kafka.clients.CommonClientConfigsTest$2.class org.apache.kafka.clients.ApiVersionsTest.class org.apache.kafka.clients.MockClient$2.class org.apache.kafka.clients.MockClient$ConnectionState.class org.apache.kafka.clients.CommonClientConfigsTest.class org.apache.kafka.clients.MockClient.class org.apache.kafka.clients.CommonClientConfigsTest$1.class org.apache.kafka.clients.MetadataTest.class org.apache.kafka.clients.MockClient$RequestMatcher.class org.apache.kafka.common.header.internals.RecordHeadersTest.class org.apache.kafka.common.PartitionInfoTest.class org.apache.kafka.common.resource.ResourceFilterTest.class org.apache.kafka.common.resource.ResourceTypeTest.class org.apache.kafka.common.resource.ResourceTypeTest$AclResourceTypeTestInfo.class org.apache.kafka.common.record.CompressionTypeTest.class org.apache.kafka.common.record.KafkaLZ4Test$Payload.class org.apache.kafka.common.record.FileLogInputStreamTest.class org.apache.kafka.common.record.DefaultRecordBatchTest.class org.apache.kafka.common.record.KafkaLZ4Test.class org.apache.kafka.common.record.ByteBufferLogInputStreamTest.class org.apache.kafka.common.record.MemoryRecordsTest.class org.apache.kafka.common.record.ControlRecordTypeTest.class org.apache.kafka.common.record.DefaultRecordTest.class org.apache.kafka.common.record.MemoryRecordsTest$2.class org.apache.kafka.common.record.SimpleMemoryRecordsTest.class org.apache.kafka.common.record.MemoryRecordsBuilderTest.class org.apache.kafka.common.record.BufferSupplierTest.class org.apache.kafka.common.record.LazyDownConversionRecordsTest$ParameterizedConversionTest.class org.apache.kafka.common.record.LegacyRecordTest.class org.apache.kafka.common.record.LazyDownConversionRecordsTest.class org.apache.kafka.common.record.MultiRecordsSendTest$NonOverflowingByteBufferChannel.class org.apache.kafka.common.record.SimpleLegacyRecordTest.class org.apache.kafka.common.record.FileRecordsTest.class org.apache.kafka.common.record.MemoryRecordsTest$1.class org.apache.kafka.common.record.EndTransactionMarkerTest.class org.apache.kafka.common.record.AbstractLegacyRecordBatchTest.class org.apache.kafka.common.record.MemoryRecordsTest$3.class org.apache.kafka.common.record.MultiRecordsSendTest$1.class org.apache.kafka.common.record.MemoryRecordsTest$RetainNonNullKeysFilter.class org.apache.kafka.common.record.MemoryRecordsTest$4.class org.apache.kafka.common.record.MultiRecordsSendTest.class org.apache.kafka.common.serialization.SerializationTest.class org.apache.kafka.common.serialization.SerializationTest$DummyClass.class org.apache.kafka.common.serialization.SerializationTest$1.class org.apache.kafka.common.network.SslTransportLayerTest$TestSslChannelBuilder$TestSslTransportLayer.class org.apache.kafka.common.network.CertStores.class org.apache.kafka.common.network.SslTransportLayerTest$3.class org.apache.kafka.common.network.ChannelBuildersTest.class org.apache.kafka.common.network.SslSelectorTest$TestSslChannelBuilder.class org.apache.kafka.common.network.SelectorTest$1.class org.apache.kafka.common.network.SslTransportLayerTest.class org.apache.kafka.common.network.SslSender.class org.apache.kafka.common.network.SslTransportLayerTest$4.class org.apache.kafka.common.network.SslTransportLayerTest$TestSslChannelBuilder.class org.apache.kafka.common.network.NioEchoServer.class org.apache.kafka.common.network.ChannelBuildersTest$ConfigurableKafkaPrincipalBuilder.class org.apache.kafka.common.network.SslTransportLayerTest$5.class org.apache.kafka.common.network.SaslChannelBuilderTest.class org.apache.kafka.common.network.SslTransportLayerTest$TestSslChannelBuilder$ResizeableBufferSize.class org.apache.kafka.common.network.SelectorTest.class org.apache.kafka.common.network.SslSender$1.class org.apache.kafka.common.network.NioEchoServer$AcceptorThread.class org.apache.kafka.common.network.SelectorTest$ImmediatelyConnectingSelector.class org.apache.kafka.common.network.SslSelectorTest.class org.apache.kafka.common.network.SslTransportLayerTest$FailureAction.class org.apache.kafka.common.network.SslSelectorTest$1.class org.apache.kafka.common.network.SslSelectorTest$TestSslChannelBuilder$TestSslTransportLayer.class org.apache.kafka.common.network.EchoServer$2.class org.apache.kafka.common.network.ChannelBuildersTest$OldPrincipalBuilder.class org.apache.kafka.common.network.SslSelectorTest$2.class org.apache.kafka.common.network.SelectorTest$2.class org.apache.kafka.common.network.SslSender$NaiveTrustManager.class org.apache.kafka.common.network.EchoServer.class org.apache.kafka.common.network.SelectorTest$4.class org.apache.kafka.common.network.EchoServer$1.class org.apache.kafka.common.network.NetworkTestUtils.class org.apache.kafka.common.network.NioEchoServer$MetricType.class org.apache.kafka.common.network.SelectorTest$3.class org.apache.kafka.common.network.PlaintextSender$1.class org.apache.kafka.common.network.SslTransportLayerTest$2.class org.apache.kafka.common.network.PlaintextSender.class org.apache.kafka.common.network.SslTransportLayerTest$1.class org.apache.kafka.common.network.ChannelBuildersTest$OldPrincipalBuilder$1.class org.apache.kafka.common.ClusterTest.class org.apache.kafka.common.KafkaFutureTest$WaiterThread.class org.apache.kafka.common.requests.ProduceRequestTest.class org.apache.kafka.common.requests.RequestContextTest.class org.apache.kafka.common.requests.ApiVersionsResponseTest.class org.apache.kafka.common.requests.RequestHeaderTest.class org.apache.kafka.common.requests.DescribeAclsRequestTest.class org.apache.kafka.common.requests.LeaderAndIsrResponseTest.class org.apache.kafka.common.requests.DeleteAclsResponseTest.class org.apache.kafka.common.requests.ByteBufferChannel.class org.apache.kafka.common.requests.CreateAclsRequestTest.class org.apache.kafka.common.requests.DescribeAclsResponseTest.class org.apache.kafka.common.requests.RequestResponseTest.class org.apache.kafka.common.requests.StopReplicaResponseTest.class org.apache.kafka.common.requests.DeleteAclsRequestTest.class org.apache.kafka.common.requests.ControlRequestTest.class org.apache.kafka.common.cache.LRUCacheTest.class org.apache.kafka.common.KafkaFutureTest.class org.apache.kafka.common.security.ssl.SslFactoryTest.class org.apache.kafka.common.security.ssl.SslPrincipalMapperTest.class org.apache.kafka.common.security.SaslExtensionsTest.class org.apache.kafka.common.security.scram.internals.ScramMessagesTest.class org.apache.kafka.common.security.scram.internals.ScramFormatterTest.class org.apache.kafka.common.security.scram.internals.ScramCredentialUtilsTest.class org.apache.kafka.common.security.scram.internals.ScramSaslServerTest.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$4.class org.apache.kafka.common.security.authenticator.ClientAuthenticationFailureTest.class org.apache.kafka.common.security.authenticator.TestDigestLoginModule.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$TestPlainLoginModule.class org.apache.kafka.common.security.authenticator.SaslServerAuthenticatorTest.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$TestLogin.class org.apache.kafka.common.security.authenticator.TestJaasConfig.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$TestLoginCallbackHandler.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$3.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$2$1.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$AlternateSaslChannelBuilder$1.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$AlternateLoginCallbackHandler.class org.apache.kafka.common.security.authenticator.TestDigestLoginModule$DigestServerCallbackHandler.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$TestServerCallbackHandler.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$1.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$InvalidScramServerCallbackHandler.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$AlternateSaslChannelBuilder.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$TestClientCallbackHandler.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorFailureDelayTest.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$2.class org.apache.kafka.common.security.authenticator.LoginManagerTest.class org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest$3$1.class org.apache.kafka.common.security.auth.KafkaPrincipalTest.class org.apache.kafka.common.security.auth.DefaultKafkaPrincipalBuilderTest$1.class org.apache.kafka.common.security.auth.DefaultKafkaPrincipalBuilderTest.class org.apache.kafka.common.security.auth.DefaultKafkaPrincipalBuilderTest$DummyPrincipal.class org.apache.kafka.common.security.TestSecurityConfig.class org.apache.kafka.common.security.JaasContextTest.class org.apache.kafka.common.security.kerberos.KerberosRuleTest.class org.apache.kafka.common.security.kerberos.KerberosNameTest.class org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenMock.class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackTest$1.class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackTest.class org.apache.kafka.common.security.oauthbearer.OAuthBearerSaslClienCallbackHandlerTest.class org.apache.kafka.common.security.oauthbearer.OAuthBearerSaslClienCallbackHandlerTest$1.class org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallbackTest$1.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLoginTest$TestExpiringCredentialRefreshingLogin$1.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLoginTest$TestExpiringCredentialRefreshingLogin.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshConfigTest.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLoginTest$2.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLoginTest$1.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLoginTest.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLoginTest$TestLoginContextFactory$1.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLoginTest$TestLoginContextFactory.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLoginTest$TestLoginContext.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerClientInitialResponseTest.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslServerTest$1.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClientTest$ExtensionsCallbackHandler.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClientTest.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClientTest$1.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslServerTest$2.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClientTest$ExtensionsCallbackHandler$1.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslServerTest.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerScopeUtilsTest.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJwsTest.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationUtilsTest.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredValidatorCallbackHandlerTest.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredLoginCallbackHandlerTest.class org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallbackTest.class org.apache.kafka.common.security.oauthbearer.OAuthBearerExtensionsValidatorCallbackTest.class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModuleTest.class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModuleTest$TestCallbackHandler.class org.apache.kafka.common.security.plain.internals.PlainSaslServerTest.class org.apache.kafka.common.message.ControlledShutdownResponseData.class org.apache.kafka.common.message.DeleteGroupsResponseData$DeletableGroupResultSet.class org.apache.kafka.common.message.LeaderAndIsrResponseData.class org.apache.kafka.common.message.SaslHandshakeRequestData.class org.apache.kafka.common.message.ApiVersionsResponseData$ApiVersionsResponseKeySet.class org.apache.kafka.common.message.AlterConfigsRequestData$AlterConfigsResourceSet.class org.apache.kafka.common.message.DescribeGroupsResponseData$DescribedGroupMember.class org.apache.kafka.common.message.StopReplicaRequestData$StopReplicaRequestPartitionV0.class org.apache.kafka.common.message.DeleteRecordsRequestData$DeleteRecordsPartition.class org.apache.kafka.common.message.OffsetCommitResponseData$OffsetCommitResponseTopic.class org.apache.kafka.common.message.DeleteAclsResponseData.class org.apache.kafka.common.message.OffsetFetchResponseData.class org.apache.kafka.common.message.CreateAclsRequestData.class org.apache.kafka.common.message.DescribeAclsResponseData$DescribeAclsResource.class org.apache.kafka.common.message.AddPartitionsToTxnResponseData$AddPartitionsToTxnTopicResult.class org.apache.kafka.common.message.JoinGroupRequestData$JoinGroupRequestProtocol.class org.apache.kafka.common.message.LeaderAndIsrRequestData$LeaderAndIsrRequestTopicState.class org.apache.kafka.common.message.AddPartitionsToTxnResponseData.class org.apache.kafka.common.message.OffsetFetchResponseData$OffsetFetchResponseTopic.class org.apache.kafka.common.message.DescribeGroupsRequestData.class org.apache.kafka.common.message.DeleteGroupsRequestData.class org.apache.kafka.common.message.ElectPreferredLeadersResponseData$PartitionResult.class org.apache.kafka.common.message.DeleteRecordsRequestData.class org.apache.kafka.common.message.DeleteAclsRequestData.class org.apache.kafka.common.message.CreateTopicsResponseData$CreatableTopicResultSet.class org.apache.kafka.common.message.RenewDelegationTokenRequestData.class org.apache.kafka.common.message.AlterReplicaLogDirsResponseData$AlterReplicaLogDirTopicResult.class org.apache.kafka.common.message.SaslHandshakeResponseData.class org.apache.kafka.common.message.ExpireDelegationTokenRequestData.class org.apache.kafka.common.message.OffsetForLeaderEpochResponseData$OffsetForLeaderTopicResult.class org.apache.kafka.common.message.ListOffsetRequestData$ListOffsetTopic.class org.apache.kafka.common.message.DescribeLogDirsRequestData.class org.apache.kafka.common.message.DescribeConfigsResponseData.class org.apache.kafka.common.message.WriteTxnMarkersRequestData$WritableTxnMarkerTopic.class org.apache.kafka.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic.class org.apache.kafka.common.message.DescribeDelegationTokenResponseData$DescribedDelegationToken.class org.apache.kafka.common.message.DeleteRecordsResponseData$DeleteRecordsPartitionResult.class org.apache.kafka.common.message.LeaderAndIsrRequestData$LeaderAndIsrLiveLeader.class org.apache.kafka.common.message.MetadataResponseData.class org.apache.kafka.common.message.ProduceRequestData.class org.apache.kafka.common.message.LeaveGroupRequestData.class org.apache.kafka.common.message.AddPartitionsToTxnRequestData$AddPartitionsToTxnTopicSet.class org.apache.kafka.common.message.CreatePartitionsRequestData$CreatePartitionsTopic.class org.apache.kafka.common.message.ProduceResponseData$PartitionProduceResponse.class org.apache.kafka.common.message.DeleteTopicsResponseData.class org.apache.kafka.common.message.TxnOffsetCommitRequestData$TxnOffsetCommitRequestPartition.class org.apache.kafka.common.message.FindCoordinatorResponseData.class org.apache.kafka.common.message.DescribeConfigsRequestData$DescribeConfigsResource.class org.apache.kafka.common.message.CreateTopicsResponseData.class org.apache.kafka.common.message.MetadataResponseData$MetadataResponseBrokerSet.class org.apache.kafka.common.message.ApiVersionsRequestData.class org.apache.kafka.common.message.AlterReplicaLogDirsRequestData.class org.apache.kafka.common.message.OffsetForLeaderEpochRequestData.class org.apache.kafka.common.message.SaslAuthenticateRequestData.class org.apache.kafka.common.message.DeleteRecordsResponseData.class org.apache.kafka.common.message.InitProducerIdRequestData.class org.apache.kafka.common.message.DescribeLogDirsRequestData$DescribableLogDirTopic.class org.apache.kafka.common.message.LeaveGroupResponseData.class org.apache.kafka.common.message.FetchRequestData.class org.apache.kafka.common.message.CreatePartitionsResponseData$CreatePartitionsTopicResult.class org.apache.kafka.common.message.UpdateMetadataRequestData$UpdateMetadataRequestEndpoint.class org.apache.kafka.common.message.CreateTopicsRequestData$CreatableTopic.class org.apache.kafka.common.message.ListGroupsResponseData$ListedGroup.class org.apache.kafka.common.message.DescribeAclsRequestData.class org.apache.kafka.common.message.JoinGroupRequestData$JoinGroupRequestProtocolSet.class org.apache.kafka.common.message.LeaderAndIsrRequestData$LeaderAndIsrRequestPartitionState.class org.apache.kafka.common.message.SyncGroupRequestData$SyncGroupRequestAssignment.class org.apache.kafka.common.message.AddOffsetsToTxnRequestData.class org.apache.kafka.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition.class org.apache.kafka.common.message.AddPartitionsToTxnResponseData$AddPartitionsToTxnTopicResultSet.class org.apache.kafka.common.message.UpdateMetadataRequestData$UpdateMetadataRequestTopicState.class org.apache.kafka.common.message.AddPartitionsToTxnRequestData$AddPartitionsToTxnTopic.class org.apache.kafka.common.message.ElectPreferredLeadersResponseData$ReplicaElectionResult.class org.apache.kafka.common.message.OffsetCommitRequestData$OffsetCommitRequestPartition.class org.apache.kafka.common.message.DescribeConfigsRequestData.class org.apache.kafka.common.message.ProduceRequestData$TopicProduceData.class org.apache.kafka.common.message.DescribeConfigsResponseData$DescribeConfigsSynonym.class org.apache.kafka.common.message.DeleteAclsRequestData$DeleteAclsFilter.class org.apache.kafka.common.message.SyncGroupResponseData.class org.apache.kafka.common.message.AddPartitionsToTxnResponseData$AddPartitionsToTxnPartitionResultSet.class org.apache.kafka.common.message.ListOffsetRequestData.class org.apache.kafka.common.message.DescribeAclsResponseData$AclDescription.class org.apache.kafka.common.message.DeleteTopicsRequestData.class org.apache.kafka.common.message.ListGroupsRequestData.class org.apache.kafka.common.message.UpdateMetadataRequestData.class org.apache.kafka.common.message.AlterConfigsRequestData$AlterableConfig.class org.apache.kafka.common.message.OffsetFetchRequestData$OffsetFetchRequestTopic.class org.apache.kafka.common.message.AddOffsetsToTxnResponseData.class org.apache.kafka.common.message.OffsetCommitRequestData.class org.apache.kafka.common.message.ElectPreferredLeadersRequestData.class org.apache.kafka.common.message.OffsetFetchResponseData$OffsetFetchResponsePartition.class org.apache.kafka.common.message.FetchRequestData$FetchableTopic.class org.apache.kafka.common.message.DeleteRecordsRequestData$DeleteRecordsTopic.class org.apache.kafka.common.message.ListGroupsResponseData.class org.apache.kafka.common.message.UpdateMetadataRequestData$UpdateMetadataRequestPartitionStateV0.class org.apache.kafka.common.message.RequestHeaderData.class org.apache.kafka.common.message.ElectPreferredLeadersRequestData$TopicPartitions.class org.apache.kafka.common.message.AlterReplicaLogDirsRequestData$AlterReplicaLogDirTopic.class org.apache.kafka.common.message.CreateDelegationTokenRequestData.class org.apache.kafka.common.message.WriteTxnMarkersResponseData.class org.apache.kafka.common.message.MetadataResponseData$MetadataResponsePartition.class org.apache.kafka.common.message.DeleteGroupsResponseData$DeletableGroupResult.class org.apache.kafka.common.message.ResponseHeaderData.class org.apache.kafka.common.message.AlterReplicaLogDirsResponseData.class org.apache.kafka.common.message.MetadataResponseData$MetadataResponseBroker.class org.apache.kafka.common.message.ElectPreferredLeadersResponseData.class org.apache.kafka.common.message.CreateAclsRequestData$CreatableAcl.class org.apache.kafka.common.message.DescribeDelegationTokenRequestData$DescribeDelegationTokenOwner.class org.apache.kafka.common.message.CreateTopicsRequestData$CreateableTopicConfig.class org.apache.kafka.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentSet.class org.apache.kafka.common.message.MetadataRequestData.class org.apache.kafka.common.message.DescribeDelegationTokenResponseData$DescribedDelegationTokenRenewer.class org.apache.kafka.common.message.HeartbeatResponseData.class org.apache.kafka.common.message.ListOffsetRequestData$ListOffsetPartition.class org.apache.kafka.common.message.ControlledShutdownRequestData.class org.apache.kafka.common.message.WriteTxnMarkersRequestData.class org.apache.kafka.common.message.AlterConfigsRequestData.class org.apache.kafka.common.message.ListOffsetResponseData.class org.apache.kafka.common.message.AlterConfigsRequestData$AlterConfigsResource.class org.apache.kafka.common.message.DescribeDelegationTokenRequestData.class org.apache.kafka.common.message.CreatePartitionsRequestData$CreatePartitionsAssignment.class org.apache.kafka.common.message.FetchResponseData$AbortedTransaction.class org.apache.kafka.common.message.FindCoordinatorRequestData.class org.apache.kafka.common.message.OffsetFetchRequestData.class org.apache.kafka.common.message.DeleteAclsResponseData$DeleteAclsFilterResult.class org.apache.kafka.common.message.ApiVersionsResponseData$ApiVersionsResponseKey.class org.apache.kafka.common.message.MessageTest.class org.apache.kafka.common.message.UpdateMetadataResponseData.class org.apache.kafka.common.message.ApiMessageFactory.class org.apache.kafka.common.message.SaslAuthenticateResponseData.class org.apache.kafka.common.message.LeaderAndIsrRequestData$LeaderAndIsrRequestPartitionStateV0.class org.apache.kafka.common.message.OffsetCommitResponseData.class org.apache.kafka.common.message.AlterConfigsResponseData$AlterConfigsResourceResponse.class org.apache.kafka.common.message.CreateTopicsRequestData$CreateableTopicConfigSet.class org.apache.kafka.common.message.DeleteRecordsResponseData$DeleteRecordsTopicResult.class org.apache.kafka.common.message.ControlledShutdownResponseData$RemainingPartitionSet.class org.apache.kafka.common.message.AddPartitionsToTxnRequestData.class org.apache.kafka.common.message.MetadataRequestData$MetadataRequestTopic.class org.apache.kafka.common.message.StopReplicaRequestData$StopReplicaRequestTopic.class org.apache.kafka.common.message.TxnOffsetCommitResponseData.class org.apache.kafka.common.message.CreateDelegationTokenRequestData$CreatableRenewers.class org.apache.kafka.common.message.CreateTopicsRequestData.class org.apache.kafka.common.message.UpdateMetadataRequestData$UpdateMetadataRequestBroker.class org.apache.kafka.common.message.FetchRequestData$FetchPartition.class org.apache.kafka.common.message.DescribeGroupsResponseData$DescribedGroup.class org.apache.kafka.common.message.StopReplicaResponseData$StopReplicaResponsePartition.class org.apache.kafka.common.message.SyncGroupRequestData.class org.apache.kafka.common.message.OffsetCommitResponseData$OffsetCommitResponsePartition.class org.apache.kafka.common.message.DescribeAclsResponseData.class org.apache.kafka.common.message.InitProducerIdResponseData.class org.apache.kafka.common.message.DescribeConfigsResponseData$DescribeConfigsResourceResult.class org.apache.kafka.common.message.DescribeConfigsResponseData$DescribeConfigsResult.class org.apache.kafka.common.message.FetchResponseData$FetchableTopicResponse.class org.apache.kafka.common.message.WriteTxnMarkersRequestData$WritableTxnMarker.class org.apache.kafka.common.message.CreateTopicsRequestData$CreatableReplicaAssignment.class org.apache.kafka.common.message.ProduceRequestData$PartitionProduceData.class org.apache.kafka.common.message.FetchRequestData$ForgottenTopic.class org.apache.kafka.common.message.AlterConfigsRequestData$AlterableConfigSet.class org.apache.kafka.common.message.WriteTxnMarkersResponseData$WritableTxnMarkerPartitionResult.class org.apache.kafka.common.message.DeleteTopicsResponseData$DeletableTopicResult.class org.apache.kafka.common.message.WriteTxnMarkersResponseData$WritableTxnMarkerResult.class org.apache.kafka.common.message.AlterReplicaLogDirsResponseData$AlterReplicaLogDirPartitionResult.class org.apache.kafka.common.message.MetadataResponseData$MetadataResponseTopicSet.class org.apache.kafka.common.message.HeartbeatRequestData.class org.apache.kafka.common.message.CreateTopicsResponseData$CreatableTopicResult.class org.apache.kafka.common.message.AddPartitionsToTxnResponseData$AddPartitionsToTxnPartitionResult.class #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	无