kafka_2.12-0.10.1.1-test.jar

<dependency>
	<groupId>org.apache.kafka</groupId>
	<artifactId>kafka_2.12</artifactId>
	<version>0.10.1.1</version>
</dependency>

org.apache.kafka:kafka_2.12:0.10.1.1

META-INF/MANIFEST.MF
LICENSE
NOTICE
integration.kafka.api.GroupCoordinatorIntegrationTest.class
kafka.admin.AclCommandTest.class
kafka.admin.AddPartitionsTest.class
kafka.admin.AdminRackAwareTest.class
kafka.admin.AdminTest.class
kafka.admin.ConfigCommandTest$$anon$1.class
kafka.admin.ConfigCommandTest$$anon$2.class
kafka.admin.ConfigCommandTest$$anon$3.class
kafka.admin.ConfigCommandTest$$anon$4.class
kafka.admin.ConfigCommandTest$$anon$5.class
kafka.admin.ConfigCommandTest.class
kafka.admin.DeleteConsumerGroupTest.class
kafka.admin.DeleteTopicTest.class
kafka.admin.RackAwareTest.class
kafka.admin.ReassignPartitionsClusterTest.class
kafka.admin.ReassignPartitionsCommandArgsTest$$anon$1.class
kafka.admin.ReassignPartitionsCommandArgsTest.class
kafka.admin.ReassignPartitionsCommandTest$$anon$1.class
kafka.admin.ReassignPartitionsCommandTest$$anon$2.class
kafka.admin.ReassignPartitionsCommandTest$$anon$3.class
kafka.admin.ReassignPartitionsCommandTest$$anon$4.class
kafka.admin.ReassignPartitionsCommandTest$$anon$5.class
kafka.admin.ReassignPartitionsCommandTest$$anon$6.class
kafka.admin.ReassignPartitionsCommandTest.class
kafka.admin.ReplicaDistributions$.class
kafka.admin.ReplicaDistributions.class
kafka.admin.ReplicationQuotaUtils$.class
kafka.admin.ReplicationQuotaUtils.class
kafka.admin.TestAdminUtils.class
kafka.admin.TopicCommandTest.class
kafka.api.AdminClientTest.class
kafka.api.ApiUtilsTest$.class
kafka.api.ApiUtilsTest.class
kafka.api.AuthorizerIntegrationTest.class
kafka.api.BaseConsumerTest$ConsumerAssignmentPoller$$anon$1.class
kafka.api.BaseConsumerTest$ConsumerAssignmentPoller.class
kafka.api.BaseConsumerTest$CountConsumerCommitCallback.class
kafka.api.BaseConsumerTest$TestConsumerReassignmentListener.class
kafka.api.BaseConsumerTest.class
kafka.api.BaseProducerSendTest$callback$3$.class
kafka.api.BaseProducerSendTest$callback$4$.class
kafka.api.BaseProducerSendTest$CloseCallback$1.class
kafka.api.BaseProducerSendTest.class
kafka.api.BaseQuotaTest.class
kafka.api.Both$.class
kafka.api.Both.class
kafka.api.ClientIdQuotaTest.class
kafka.api.ConsumerBounceTest$BounceBrokerScheduler.class
kafka.api.ConsumerBounceTest.class
kafka.api.EndToEndAuthorizationTest.class
kafka.api.EndToEndClusterIdTest$.class
kafka.api.EndToEndClusterIdTest$MockBrokerMetricsReporter$.class
kafka.api.EndToEndClusterIdTest$MockBrokerMetricsReporter.class
kafka.api.EndToEndClusterIdTest$MockConsumerMetricsReporter$.class
kafka.api.EndToEndClusterIdTest$MockConsumerMetricsReporter.class
kafka.api.EndToEndClusterIdTest$MockProducerMetricsReporter$.class
kafka.api.EndToEndClusterIdTest$MockProducerMetricsReporter.class
kafka.api.EndToEndClusterIdTest.class
kafka.api.FetchRequestTest.class
kafka.api.FixedPortTestUtils$.class
kafka.api.FixedPortTestUtils.class
kafka.api.IntegrationTestHarness.class
kafka.api.KafkaSasl$.class
kafka.api.KafkaSasl.class
kafka.api.PlaintextConsumerTest$$anon$1.class
kafka.api.PlaintextConsumerTest$$anon$2.class
kafka.api.PlaintextConsumerTest.class
kafka.api.PlaintextProducerSendTest.class
kafka.api.ProducerBounceTest$ProducerScheduler.class
kafka.api.ProducerBounceTest.class
kafka.api.ProducerFailureHandlingTest.class
kafka.api.RackAwareAutoTopicCreationTest.class
kafka.api.RequestResponseSerializationTest.class
kafka.api.SaslMultiMechanismConsumerTest.class
kafka.api.SaslPlainPlaintextConsumerTest.class
kafka.api.SaslPlainSslEndToEndAuthorizationTest.class
kafka.api.SaslPlaintextConsumerTest.class
kafka.api.SaslSetup.class
kafka.api.SaslSetupMode.class
kafka.api.SaslSslConsumerTest.class
kafka.api.SaslSslEndToEndAuthorizationTest.class
kafka.api.SaslTestHarness.class
kafka.api.SerializationTestUtils$.class
kafka.api.SerializationTestUtils.class
kafka.api.SslConsumerTest.class
kafka.api.SslEndToEndAuthorizationTest.class
kafka.api.SslProducerSendTest.class
kafka.api.test.ProducerCompressionTest$.class
kafka.api.test.ProducerCompressionTest.class
kafka.api.UserClientIdQuotaTest.class
kafka.api.UserQuotaTest.class
kafka.api.ZkSasl$.class
kafka.api.ZkSasl.class
kafka.AppenderStringSerializer$.class
kafka.AppenderStringSerializer.class
kafka.cluster.BrokerEndPointTest.class
kafka.common.ConfigTest.class
kafka.common.TopicTest.class
kafka.common.ZkNodeChangeNotificationListenerTest$$anon$1.class
kafka.common.ZkNodeChangeNotificationListenerTest.class
kafka.consumer.ConsumerIteratorTest$FailDecoder$.class
kafka.consumer.ConsumerIteratorTest$FailDecoder.class
kafka.consumer.ConsumerIteratorTest.class
kafka.consumer.PartitionAssignorTest$.class
kafka.consumer.PartitionAssignorTest$Scenario$.class
kafka.consumer.PartitionAssignorTest$Scenario.class
kafka.consumer.PartitionAssignorTest$StaticSubscriptionInfo$.class
kafka.consumer.PartitionAssignorTest$StaticSubscriptionInfo.class
kafka.consumer.PartitionAssignorTest$SubscriptionInfo.class
kafka.consumer.PartitionAssignorTest$WildcardSubscriptionInfo$.class
kafka.consumer.PartitionAssignorTest$WildcardSubscriptionInfo.class
kafka.consumer.PartitionAssignorTest.class
kafka.consumer.TopicFilterTest.class
kafka.consumer.ZookeeperConsumerConnectorTest$$anon$1.class
kafka.consumer.ZookeeperConsumerConnectorTest$$anon$2.class
kafka.consumer.ZookeeperConsumerConnectorTest$$anon$3.class
kafka.consumer.ZookeeperConsumerConnectorTest$TestConsumerRebalanceListener.class
kafka.consumer.ZookeeperConsumerConnectorTest.class
kafka.controller.ControllerFailoverTest$$anon$1.class
kafka.controller.ControllerFailoverTest.class
kafka.controller.MockChannelManager.class
kafka.coordinator.GroupCoordinatorResponseTest$$anon$1.class
kafka.coordinator.GroupCoordinatorResponseTest$$anon$2.class
kafka.coordinator.GroupCoordinatorResponseTest.class
kafka.coordinator.GroupCoordinatorTest.class
kafka.coordinator.GroupMetadataManagerTest$$anon$1.class
kafka.coordinator.GroupMetadataManagerTest.class
kafka.coordinator.GroupMetadataTest.class
kafka.coordinator.MemberMetadataTest.class
kafka.integration.AutoOffsetResetTest.class
kafka.integration.BaseTopicMetadataTest.class
kafka.integration.FetcherTest.class
kafka.integration.KafkaServerTestHarness.class
kafka.integration.MinIsrConfigTest.class
kafka.integration.PlaintextTopicMetadataTest.class
kafka.integration.PrimitiveApiTest.class
kafka.integration.ProducerConsumerTestHarness.class
kafka.integration.SaslPlaintextTopicMetadataTest.class
kafka.integration.SaslSslTopicMetadataTest.class
kafka.integration.SslTopicMetadataTest.class
kafka.integration.UncleanLeaderElectionTest.class
kafka.javaapi.consumer.ZookeeperConsumerConnectorTest.class
kafka.javaapi.message.BaseMessageSetTestCases.class
kafka.javaapi.message.ByteBufferMessageSetTest.class
kafka.KafkaTest$ExitCalled.class
kafka.KafkaTest$NoExitSecurityManager.class
kafka.KafkaTest.class
kafka.log.BrokerCompressionTest$.class
kafka.log.BrokerCompressionTest.class
kafka.log.CleanerTest.class
kafka.log.FakeOffsetMap.class
kafka.log.FileMessageSetTest.class
kafka.log.LogCleanerIntegrationTest$.class
kafka.log.LogCleanerIntegrationTest.class
kafka.log.LogCleanerLagIntegrationTest$.class
kafka.log.LogCleanerLagIntegrationTest.class
kafka.log.LogCleanerManagerTest.class
kafka.log.LogConfigTest.class
kafka.log.LogManagerTest.class
kafka.log.LogSegmentTest.class
kafka.log.LogTest.class
kafka.log.OffsetIndexTest.class
kafka.log.OffsetMapTest$.class
kafka.log.OffsetMapTest.class
kafka.log.TestCrcPerformance$.class
kafka.log.TestCrcPerformance.class
kafka.log.TimeIndexTest.class
kafka.message.BaseMessageSetTestCases$StubByteChannel.class
kafka.message.BaseMessageSetTestCases.class
kafka.message.ByteBufferMessageSetTest.class
kafka.message.MessageCompressionTest.class
kafka.message.MessageTest.class
kafka.message.MessageTestVal$.class
kafka.message.MessageTestVal.class
kafka.message.MessageWriterTest.class
kafka.metrics.KafkaTimerTest$ManualClock.class
kafka.metrics.KafkaTimerTest.class
kafka.metrics.MetricsTest.class
kafka.network.SocketServerTest$$anon$2$$anon$1.class
kafka.network.SocketServerTest$$anon$2.class
kafka.network.SocketServerTest.class
kafka.producer.AsyncProducerTest$$anon$1.class
kafka.producer.AsyncProducerTest$$anon$2.class
kafka.producer.AsyncProducerTest$$anon$3.class
kafka.producer.AsyncProducerTest$NegativePartitioner$.class
kafka.producer.AsyncProducerTest$NegativePartitioner.class
kafka.producer.AsyncProducerTest.class
kafka.producer.ProducerTest.class
kafka.producer.SyncProducerTest.class
kafka.security.auth.AclTest.class
kafka.security.auth.OperationTest.class
kafka.security.auth.PermissionTypeTest.class
kafka.security.auth.ResourceTypeTest.class
kafka.security.auth.SimpleAclAuthorizerTest.class
kafka.security.auth.ZkAuthorizationTest.class
kafka.security.minikdc.MiniKdc$.class
kafka.security.minikdc.MiniKdc.class
kafka.server.AbstractFetcherThreadTest$CorruptingFetcherThread$.class
kafka.server.AbstractFetcherThreadTest$CorruptingFetcherThread.class
kafka.server.AbstractFetcherThreadTest$DummyFetcherThread$.class
kafka.server.AbstractFetcherThreadTest$DummyFetcherThread.class
kafka.server.AbstractFetcherThreadTest$DummyFetchRequest.class
kafka.server.AbstractFetcherThreadTest$TestPartitionData.class
kafka.server.AbstractFetcherThreadTest.class
kafka.server.AdvertiseBrokerTest.class
kafka.server.ApiVersionsRequestTest$.class
kafka.server.ApiVersionsRequestTest.class
kafka.server.BaseReplicaFetchTest.class
kafka.server.BaseRequestTest.class
kafka.server.ClientQuotaManagerTest$UserClient$.class
kafka.server.ClientQuotaManagerTest$UserClient.class
kafka.server.ClientQuotaManagerTest.class
kafka.server.ControlledShutdownLeaderSelectorTest.class
kafka.server.CreateTopicsRequestTest.class
kafka.server.DelayedOperationTest$MockDelayedOperation.class
kafka.server.DelayedOperationTest.class
kafka.server.DeleteTopicsRequestTest.class
kafka.server.DynamicConfigChangeTest.class
kafka.server.DynamicConfigTest.class
kafka.server.EdgeCaseRequestTest.class
kafka.server.FetchRequestTest$$anonfun$1.class
kafka.server.FetchRequestTest$$anonfun$2.class
kafka.server.FetchRequestTest.class
kafka.server.HighwatermarkPersistenceTest.class
kafka.server.IsrExpirationTest.class
kafka.server.KafkaConfigTest.class
kafka.server.KafkaMetricReporterClusterIdTest$.class
kafka.server.KafkaMetricReporterClusterIdTest$MockBrokerMetricsReporter$.class
kafka.server.KafkaMetricReporterClusterIdTest$MockBrokerMetricsReporter.class
kafka.server.KafkaMetricReporterClusterIdTest$MockKafkaMetricsReporter$.class
kafka.server.KafkaMetricReporterClusterIdTest$MockKafkaMetricsReporter.class
kafka.server.KafkaMetricReporterClusterIdTest.class
kafka.server.LeaderElectionTest.class
kafka.server.LogOffsetTest$$anon$2.class
kafka.server.LogOffsetTest$$anon$3$$anon$1.class
kafka.server.LogOffsetTest$$anon$3.class
kafka.server.LogOffsetTest.class
kafka.server.LogRecoveryTest.class
kafka.server.MetadataCacheTest.class
kafka.server.MetadataRequestTest.class
kafka.server.OffsetCommitTest.class
kafka.server.PlaintextReplicaFetchTest.class
kafka.server.ProduceRequestTest$$anonfun$createTopicAndFindPartitionWithLeader$2.class
kafka.server.ProduceRequestTest.class
kafka.server.ReplicaManagerQuotasTest.class
kafka.server.ReplicaManagerTest.class
kafka.server.ReplicationQuotaManagerTest.class
kafka.server.ReplicationQuotasTest.class
kafka.server.SaslApiVersionsRequestTest.class
kafka.server.SaslPlaintextReplicaFetchTest.class
kafka.server.SaslSslReplicaFetchTest.class
kafka.server.ServerGenerateBrokerIdTest.class
kafka.server.ServerGenerateClusterIdTest.class
kafka.server.ServerShutdownTest.class
kafka.server.ServerStartupTest$BrokerStateInterceptor$1.class
kafka.server.ServerStartupTest$MockKafkaServer$2.class
kafka.server.ServerStartupTest$MockKafkaServer$3$.class
kafka.server.ServerStartupTest.class
kafka.server.SessionExpireListenerTest$$anonfun$1.class
kafka.server.SessionExpireListenerTest.class
kafka.server.SimpleFetchTest.class
kafka.server.SslReplicaFetchTest.class
kafka.server.ThrottledResponseExpirationTest.class
kafka.StressTestLog$$anon$1.class
kafka.StressTestLog$.class
kafka.StressTestLog$ReaderThread.class
kafka.StressTestLog$WorkerThread.class
kafka.StressTestLog$WriterThread.class
kafka.StressTestLog.class
kafka.TestKafkaAppender$.class
kafka.TestKafkaAppender.class
kafka.TestLinearWriteSpeed$.class
kafka.TestLinearWriteSpeed$ChannelWritable.class
kafka.TestLinearWriteSpeed$LogWritable.class
kafka.TestLinearWriteSpeed$MmapWritable.class
kafka.TestLinearWriteSpeed$Writable.class
kafka.TestLinearWriteSpeed.class
#内容未全部加载，请点击展开加载全部代码(NowJava.com)