登录注册

Jar文件详情内容

kafka_2.12-2.3.0-test-sources.jar

所在目录：/org/apache/kafka/kafka_2.12/2.3.0 查看kafka_2.12所有版本文件

组织ID:	org.apache.kafka
项目ID:	kafka_2.12
版本:	2.3.0
最后修改时间:	2019-09-25 19:28:24
包类型:	jar
大小:	785.37KB

Maven引入代码:	`<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.12</artifactId> <version>2.3.0</version> </dependency>`
Gradle引入代码:	`org.apache.kafka:kafka_2.12:2.3.0`
下载Jar包:	kafka_2.12-2.3.0-test-sources.jar
Jar包内容:	展开复制 META-INF/MANIFEST.MF LICENSE NOTICE log4j.properties minikdc-krb5.conf minikdc.ldiff kafka/common/InterBrokerSendThreadTest.scala kafka/utils/LoggingTest.scala kafka/zk/ExtendedAclStoreTest.scala kafka/zk/LiteralAclStoreTest.scala kafka/tools/CustomDeserializerTest.scala kafka/tools/ReplicaVerificationToolTest.scala kafka/tools/LogCompactionTester.scala kafka/security/auth/ResourceTest.scala kafka/security/minikdc/MiniKdc.scala other/kafka.log4j.properties other/kafka/TestLinearWriteSpeed.scala other/kafka/TestPurgatoryPerformance.scala other/kafka/ReplicationQuotasTestRig.scala other/kafka/StressTestLog.scala other/kafka/TestTruncate.scala integration/kafka/api/SaslSetup.scala integration/kafka/api/SaslSslAdminClientIntegrationTest.scala integration/kafka/api/SslEndToEndAuthorizationTest.scala integration/kafka/api/RackAwareAutoTopicCreationTest.scala integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala integration/kafka/api/SaslEndToEndAuthorizationTest.scala integration/kafka/api/GroupEndToEndAuthorizationTest.scala integration/kafka/api/SaslGssapiSslEndToEndAuthorizationTest.scala integration/kafka/api/SslConsumerTest.scala integration/kafka/api/BaseQuotaTest.scala integration/kafka/api/LegacyAdminClientTest.scala integration/kafka/api/ConsumerBounceTest.scala integration/kafka/api/EndToEndClusterIdTest.scala integration/kafka/api/AbstractConsumerTest.scala integration/kafka/api/SaslSslConsumerTest.scala integration/kafka/api/MetricsTest.scala integration/kafka/api/IntegrationTestHarness.scala integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala integration/kafka/api/BaseProducerSendTest.scala integration/kafka/api/PlaintextEndToEndAuthorizationTest.scala integration/kafka/api/BaseConsumerTest.scala integration/kafka/api/UserQuotaTest.scala integration/kafka/api/ConsumerTopicCreationTest.scala integration/kafka/api/ProducerFailureHandlingTest.scala integration/kafka/api/SaslPlainSslEndToEndAuthorizationTest.scala integration/kafka/api/ClientIdQuotaTest.scala integration/kafka/api/AuthorizerIntegrationTest.scala integration/kafka/api/PlaintextConsumerTest.scala integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala integration/kafka/api/SaslPlaintextConsumerTest.scala integration/kafka/api/TransactionsTest.scala integration/kafka/api/EndToEndAuthorizationTest.scala integration/kafka/api/SaslOAuthBearerSslEndToEndAuthorizationTest.scala integration/kafka/api/CustomQuotaCallbackTest.scala integration/kafka/api/SaslPlainPlaintextConsumerTest.scala integration/kafka/api/FixedPortTestUtils.scala integration/kafka/api/GroupAuthorizerIntegrationTest.scala integration/kafka/api/PlaintextProducerSendTest.scala integration/kafka/api/AdminClientIntegrationTest.scala integration/kafka/api/SaslMultiMechanismConsumerTest.scala integration/kafka/api/ProducerCompressionTest.scala integration/kafka/api/LogAppendTimeTest.scala integration/kafka/api/AdminClientWithPoliciesIntegrationTest.scala integration/kafka/api/DescribeAuthorizedOperationsTest.scala integration/kafka/api/UserClientIdQuotaTest.scala integration/kafka/api/GroupCoordinatorIntegrationTest.scala integration/kafka/api/SslProducerSendTest.scala integration/kafka/api/TransactionsBounceTest.scala integration/kafka/server/MultipleListenersWithDefaultJaasContextTest.scala integration/kafka/server/GssapiAuthenticationTest.scala integration/kafka/server/MultipleListenersWithAdditionalJaasContextTest.scala integration/kafka/server/DynamicBrokerReconfigurationTest.scala integration/kafka/server/ScramServerStartupTest.scala integration/kafka/server/MultipleListenersWithSameSecurityProtocolBaseTest.scala integration/kafka/server/DelayedFetchTest.scala integration/kafka/network/DynamicConnectionQuotaTest.scala integration/kafka/admin/BrokerApiVersionsCommandTest.scala integration/kafka/admin/ReassignPartitionsIntegrationTest.scala integration/kafka/tools/MirrorMakerIntegrationTest.scala unit/kafka/coordinator/transaction/TransactionMetadataTest.scala unit/kafka/coordinator/transaction/ProducerIdManagerTest.scala unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala unit/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandlerTest.scala unit/kafka/coordinator/transaction/TransactionCoordinatorConcurrencyTest.scala unit/kafka/coordinator/transaction/TransactionStateManagerTest.scala unit/kafka/coordinator/transaction/TransactionLogTest.scala unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala unit/kafka/coordinator/group/GroupCoordinatorTest.scala unit/kafka/coordinator/group/GroupMetadataManagerTest.scala unit/kafka/coordinator/group/MemberMetadataTest.scala unit/kafka/coordinator/group/GroupMetadataTest.scala unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala unit/kafka/api/ApiUtilsTest.scala unit/kafka/api/ApiVersionTest.scala unit/kafka/log/AbstractLogCleanerIntegrationTest.scala unit/kafka/log/OffsetMapTest.scala unit/kafka/log/LogSegmentTest.scala unit/kafka/log/LogCleanerParameterizedIntegrationTest.scala unit/kafka/log/LogValidatorTest.scala unit/kafka/log/LogCleanerTest.scala unit/kafka/log/LogManagerTest.scala unit/kafka/log/LogConfigTest.scala unit/kafka/log/LogCleanerManagerTest.scala unit/kafka/log/LogCleanerLagIntegrationTest.scala unit/kafka/log/ProducerStateManagerTest.scala unit/kafka/log/LogTest.scala unit/kafka/log/LogCleanerIntegrationTest.scala unit/kafka/log/BrokerCompressionTest.scala unit/kafka/log/TimeIndexTest.scala unit/kafka/log/OffsetIndexTest.scala unit/kafka/log/LogUtils.scala unit/kafka/log/TransactionIndexTest.scala unit/kafka/common/ZkNodeChangeNotificationListenerTest.scala unit/kafka/KafkaConfigTest.scala unit/kafka/controller/ControllerChannelManagerTest.scala unit/kafka/controller/MockReplicaStateMachine.scala unit/kafka/controller/ControllerFailoverTest.scala unit/kafka/controller/MockPartitionStateMachine.scala unit/kafka/controller/ReplicaStateMachineTest.scala unit/kafka/controller/PartitionLeaderElectionAlgorithmsTest.scala unit/kafka/controller/TopicDeletionManagerTest.scala unit/kafka/controller/PartitionStateMachineTest.scala unit/kafka/controller/ControllerEventManagerTest.scala unit/kafka/controller/ControllerIntegrationTest.scala unit/kafka/server/ReplicaFetcherThreadTest.scala unit/kafka/server/EdgeCaseRequestTest.scala unit/kafka/server/BrokerEpochIntegrationTest.scala unit/kafka/server/ReplicaManagerTest.scala unit/kafka/server/epoch/OffsetsForLeaderEpochTest.scala unit/kafka/server/epoch/util/ReplicaFetcherMockBlockingSend.scala unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala unit/kafka/server/epoch/LeaderEpochIntegrationTest.scala unit/kafka/server/epoch/EpochDrivenReplicationProtocolAcceptanceTest.scala unit/kafka/server/ServerStartupTest.scala unit/kafka/server/DynamicConfigChangeTest.scala unit/kafka/server/ReplicationQuotasTest.scala unit/kafka/server/AbstractFetcherManagerTest.scala unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala unit/kafka/server/SaslApiVersionsRequestTest.scala unit/kafka/server/ApiVersionsRequestTest.scala unit/kafka/server/ReplicaFetchTest.scala unit/kafka/server/FetchRequestDownConversionConfigTest.scala unit/kafka/server/ServerShutdownTest.scala unit/kafka/server/SimpleFetchTest.scala unit/kafka/server/CreateTopicsRequestTest.scala unit/kafka/server/LeaderElectionTest.scala unit/kafka/server/DescribeLogDirsRequestTest.scala unit/kafka/server/DynamicConfigTest.scala unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala unit/kafka/server/AdvertiseBrokerTest.scala unit/kafka/server/ThrottledChannelExpirationTest.scala unit/kafka/server/AbstractFetcherThreadTest.scala unit/kafka/server/ServerGenerateClusterIdTest.scala unit/kafka/server/DynamicBrokerConfigTest.scala unit/kafka/server/AbstractCreateTopicsRequestTest.scala unit/kafka/server/DeleteTopicsRequestWithDeletionDisabledTest.scala unit/kafka/server/ServerGenerateBrokerIdTest.scala unit/kafka/server/KafkaConfigTest.scala unit/kafka/server/StopReplicaRequestTest.scala unit/kafka/server/DelegationTokenRequestsTest.scala unit/kafka/server/MetadataCacheTest.scala unit/kafka/server/MetadataRequestTest.scala unit/kafka/server/ClientQuotaManagerTest.scala unit/kafka/server/ServerMetricsTest.scala unit/kafka/server/ReplicaManagerQuotasTest.scala unit/kafka/server/RequestQuotaTest.scala unit/kafka/server/KafkaMetricReporterClusterIdTest.scala unit/kafka/server/ReplicationQuotaManagerTest.scala unit/kafka/server/DelayedOperationTest.scala unit/kafka/server/ProduceRequestTest.scala unit/kafka/server/AlterReplicaLogDirsRequestTest.scala unit/kafka/server/AddPartitionsToTxnRequestTest.scala unit/kafka/server/FetchRequestTest.scala unit/kafka/server/DeleteTopicsRequestTest.scala unit/kafka/server/LogRecoveryTest.scala unit/kafka/server/BaseRequestTest.scala unit/kafka/server/checkpoints/OffsetCheckpointFileTest.scala unit/kafka/server/checkpoints/LeaderEpochCheckpointFileTest.scala unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala unit/kafka/server/HighwatermarkPersistenceTest.scala unit/kafka/server/KafkaServerTest.scala unit/kafka/server/LogOffsetTest.scala unit/kafka/server/FetchSessionTest.scala unit/kafka/server/DelegationTokenRequestsOnPlainTextTest.scala unit/kafka/server/OffsetsForLeaderEpochRequestTest.scala unit/kafka/server/ListOffsetsRequestTest.scala unit/kafka/server/ISRExpirationTest.scala unit/kafka/server/KafkaApisTest.scala unit/kafka/server/DelegationTokenRequestsWithDisableTokenFeatureTest.scala unit/kafka/server/LogDirFailureTest.scala unit/kafka/network/SocketServerTest.scala unit/kafka/utils/TopicFilterTest.scala unit/kafka/utils/json/JsonValueTest.scala unit/kafka/utils/TestUtils.scala unit/kafka/utils/LogCaptureAppender.scala unit/kafka/utils/MockScheduler.scala unit/kafka/utils/JsonTest.scala unit/kafka/utils/MockTime.scala unit/kafka/utils/ThrottlerTest.scala unit/kafka/utils/ReplicationUtilsTest.scala unit/kafka/utils/timer/MockTimer.scala unit/kafka/utils/timer/TimerTest.scala unit/kafka/utils/timer/TimerTaskListTest.scala unit/kafka/utils/ShutdownableThreadTest.scala unit/kafka/utils/JaasTestUtils.scala #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	无