META-INF/MANIFEST.MF
LICENSE
NOTICE
log4j.properties
minikdc-krb5.conf
minikdc.ldiff
integration/kafka/admin/BrokerApiVersionsCommandTest.scala
integration/kafka/admin/ReassignPartitionsIntegrationTest.scala
integration/kafka/api/AdminClientTest.scala
integration/kafka/api/AuthorizerIntegrationTest.scala
integration/kafka/api/BaseConsumerTest.scala
integration/kafka/api/BaseProducerSendTest.scala
integration/kafka/api/BaseQuotaTest.scala
integration/kafka/api/ClientIdQuotaTest.scala
integration/kafka/api/ConsumerBounceTest.scala
integration/kafka/api/EndToEndAuthorizationTest.scala
integration/kafka/api/EndToEndClusterIdTest.scala
integration/kafka/api/FixedPortTestUtils.scala
integration/kafka/api/GroupCoordinatorIntegrationTest.scala
integration/kafka/api/IntegrationTestHarness.scala
integration/kafka/api/PlaintextConsumerTest.scala
integration/kafka/api/PlaintextProducerSendTest.scala
integration/kafka/api/ProducerBounceTest.scala
integration/kafka/api/ProducerCompressionTest.scala
integration/kafka/api/ProducerFailureHandlingTest.scala
integration/kafka/api/RackAwareAutoTopicCreationTest.scala
integration/kafka/api/SaslEndToEndAuthorizationTest.scala
integration/kafka/api/SaslGssapiSslEndToEndAuthorizationTest.scala
integration/kafka/api/SaslMultiMechanismConsumerTest.scala
integration/kafka/api/SaslPlainPlaintextConsumerTest.scala
integration/kafka/api/SaslPlainSslEndToEndAuthorizationTest.scala
integration/kafka/api/SaslPlaintextConsumerTest.scala
integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala
integration/kafka/api/SaslSetup.scala
integration/kafka/api/SaslSslConsumerTest.scala
integration/kafka/api/SaslTestHarness.scala
integration/kafka/api/SslConsumerTest.scala
integration/kafka/api/SslEndToEndAuthorizationTest.scala
integration/kafka/api/SslProducerSendTest.scala
integration/kafka/api/UserClientIdQuotaTest.scala
integration/kafka/api/UserQuotaTest.scala
integration/kafka/server/MultipleListenersWithSameSecurityProtocolTest.scala
integration/kafka/tools/MirrorMakerIntegrationTest.scala
kafka/security/minikdc/MiniKdc.scala
kafka/tools/ReplicaVerificationToolTest.scala
kafka/tools/TestLogCleaning.scala
other/kafka/ReplicationQuotasTestRig.scala
other/kafka/StressTestLog.scala
other/kafka/TestCrcPerformance.scala
other/kafka/TestKafkaAppender.scala
other/kafka/TestLinearWriteSpeed.scala
other/kafka/TestOffsetManager.scala
other/kafka/TestPurgatoryPerformance.scala
other/kafka/TestTruncate.scala
other/kafka.log4j.properties
unit/kafka/admin/AclCommandTest.scala
unit/kafka/admin/AddPartitionsTest.scala
unit/kafka/admin/AdminRackAwareTest.scala
unit/kafka/admin/AdminTest.scala
unit/kafka/admin/ConfigCommandTest.scala
unit/kafka/admin/DeleteConsumerGroupTest.scala
unit/kafka/admin/DeleteTopicTest.scala
unit/kafka/admin/DescribeConsumerGroupTest.scala
unit/kafka/admin/ListConsumerGroupTest.scala
unit/kafka/admin/RackAwareTest.scala
unit/kafka/admin/ReassignPartitionsClusterTest.scala
unit/kafka/admin/ReassignPartitionsCommandArgsTest.scala
unit/kafka/admin/ReassignPartitionsCommandTest.scala
unit/kafka/admin/ReplicationQuotaUtils.scala
unit/kafka/admin/TestAdminUtils.scala
unit/kafka/admin/TopicCommandTest.scala
unit/kafka/api/ApiUtilsTest.scala
unit/kafka/api/FetchRequestTest.scala
unit/kafka/api/RequestResponseSerializationTest.scala
unit/kafka/cluster/BrokerEndPointTest.scala
unit/kafka/common/ConfigTest.scala
unit/kafka/common/TopicTest.scala
unit/kafka/common/ZkNodeChangeNotificationListenerTest.scala
unit/kafka/consumer/ConsumerIteratorTest.scala
unit/kafka/consumer/PartitionAssignorTest.scala
unit/kafka/consumer/TopicFilterTest.scala
unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala
unit/kafka/controller/ControllerFailoverTest.scala
unit/kafka/coordinator/GroupCoordinatorResponseTest.scala
unit/kafka/coordinator/GroupCoordinatorTest.scala
unit/kafka/coordinator/GroupMetadataManagerTest.scala
unit/kafka/coordinator/GroupMetadataTest.scala
unit/kafka/coordinator/MemberMetadataTest.scala
unit/kafka/integration/AutoOffsetResetTest.scala
unit/kafka/integration/BaseTopicMetadataTest.scala
unit/kafka/integration/FetcherTest.scala
unit/kafka/integration/KafkaServerTestHarness.scala
unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala
unit/kafka/integration/MinIsrConfigTest.scala
unit/kafka/integration/PlaintextTopicMetadataTest.scala
unit/kafka/integration/PrimitiveApiTest.scala
unit/kafka/integration/ProducerConsumerTestHarness.scala
unit/kafka/integration/SaslPlaintextTopicMetadataTest.scala
unit/kafka/integration/SaslSslTopicMetadataTest.scala
unit/kafka/integration/SslTopicMetadataTest.scala
unit/kafka/integration/UncleanLeaderElectionTest.scala
unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala
unit/kafka/javaapi/message/BaseMessageSetTestCases.scala
unit/kafka/javaapi/message/ByteBufferMessageSetTest.scala
unit/kafka/KafkaConfigTest.scala
unit/kafka/log/BrokerCompressionTest.scala
unit/kafka/log/LogCleanerIntegrationTest.scala
unit/kafka/log/LogCleanerLagIntegrationTest.scala
unit/kafka/log/LogCleanerManagerTest.scala
unit/kafka/log/LogCleanerTest.scala
unit/kafka/log/LogConfigTest.scala
unit/kafka/log/LogManagerTest.scala
unit/kafka/log/LogSegmentTest.scala
unit/kafka/log/LogTest.scala
unit/kafka/log/LogValidatorTest.scala
unit/kafka/log/OffsetIndexTest.scala
unit/kafka/log/OffsetMapTest.scala
unit/kafka/log/TimeIndexTest.scala
unit/kafka/message/BaseMessageSetTestCases.scala
unit/kafka/message/ByteBufferMessageSetTest.scala
unit/kafka/message/MessageCompressionTest.scala
unit/kafka/message/MessageTest.scala
unit/kafka/message/MessageWriterTest.scala
unit/kafka/metrics/KafkaTimerTest.scala
unit/kafka/metrics/MetricsTest.scala
unit/kafka/network/SocketServerTest.scala
unit/kafka/producer/AsyncProducerTest.scala
unit/kafka/producer/ProducerTest.scala
unit/kafka/producer/SyncProducerTest.scala
unit/kafka/security/auth/AclTest.scala
unit/kafka/security/auth/OperationTest.scala
unit/kafka/security/auth/PermissionTypeTest.scala
unit/kafka/security/auth/ResourceTypeTest.scala
unit/kafka/security/auth/SimpleAclAuthorizerTest.scala
unit/kafka/security/auth/ZkAuthorizationTest.scala
unit/kafka/server/AbstractCreateTopicsRequestTest.scala
unit/kafka/server/AbstractFetcherThreadTest.scala
unit/kafka/server/AdvertiseBrokerTest.scala
unit/kafka/server/ApiVersionsRequestTest.scala
unit/kafka/server/ApiVersionsTest.scala
unit/kafka/server/BaseReplicaFetchTest.scala
unit/kafka/server/BaseRequestTest.scala
unit/kafka/server/ClientQuotaManagerTest.scala
unit/kafka/server/ControlledShutdownLeaderSelectorTest.scala
unit/kafka/server/CreateTopicsRequestTest.scala
unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala
unit/kafka/server/DelayedOperationTest.scala
unit/kafka/server/DeleteTopicsRequestTest.scala
unit/kafka/server/DynamicConfigChangeTest.scala
unit/kafka/server/DynamicConfigTest.scala
unit/kafka/server/EdgeCaseRequestTest.scala
unit/kafka/server/FetchRequestTest.scala
unit/kafka/server/HighwatermarkPersistenceTest.scala
unit/kafka/server/ISRExpirationTest.scala
unit/kafka/server/KafkaConfigTest.scala
unit/kafka/server/KafkaMetricReporterClusterIdTest.scala
unit/kafka/server/LeaderElectionTest.scala
unit/kafka/server/LogOffsetTest.scala
unit/kafka/server/LogRecoveryTest.scala
unit/kafka/server/MetadataCacheTest.scala
#内容未全部加载,请点击展开加载全部代码(NowJava.com)
|