登录注册

Jar文件详情内容

kafka_2.12-2.3.1-test-sources.jar

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

组织ID:	org.apache.kafka
项目ID:	kafka_2.12
版本:	2.3.1
最后修改时间:	2019-12-03 18:32:08
包类型:	jar
大小:	786.89KB

Maven引入代码:	`<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.12</artifactId> <version>2.3.1</version> </dependency>`
Gradle引入代码:	`org.apache.kafka:kafka_2.12:2.3.1`
下载Jar包:	kafka_2.12-2.3.1-test-sources.jar
Jar包内容:	展开复制 META-INF/MANIFEST.MF LICENSE NOTICE minikdc-krb5.conf minikdc.ldiff log4j.properties unit/kafka/metrics/MetricsTest.scala unit/kafka/metrics/KafkaTimerTest.scala unit/kafka/cluster/PartitionTest.scala unit/kafka/cluster/ReplicaTest.scala unit/kafka/cluster/BrokerEndPointTest.scala unit/kafka/zk/KafkaZkClientTest.scala unit/kafka/zk/AdminZkClientTest.scala unit/kafka/zk/ZooKeeperTestHarness.scala unit/kafka/zk/ZkFourLetterWords.scala unit/kafka/zk/EmbeddedZookeeper.scala unit/kafka/zk/ReassignPartitionsZNodeTest.scala unit/kafka/tools/MirrorMakerTest.scala unit/kafka/tools/ConsoleConsumerTest.scala unit/kafka/tools/DumpLogSegmentsTest.scala unit/kafka/tools/ConsoleProducerTest.scala unit/kafka/tools/ConsumerPerformanceTest.scala unit/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandlerTest.scala unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala unit/kafka/coordinator/transaction/TransactionLogTest.scala unit/kafka/coordinator/transaction/TransactionCoordinatorConcurrencyTest.scala unit/kafka/coordinator/transaction/TransactionMetadataTest.scala unit/kafka/coordinator/transaction/ProducerIdManagerTest.scala unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala unit/kafka/coordinator/transaction/TransactionStateManagerTest.scala unit/kafka/coordinator/group/GroupCoordinatorTest.scala unit/kafka/coordinator/group/GroupMetadataTest.scala unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala unit/kafka/coordinator/group/GroupMetadataManagerTest.scala unit/kafka/coordinator/group/MemberMetadataTest.scala unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala unit/kafka/security/token/delegation/DelegationTokenManagerTest.scala unit/kafka/security/auth/OperationTest.scala unit/kafka/security/auth/PermissionTypeTest.scala unit/kafka/security/auth/AclTest.scala unit/kafka/security/auth/ZkAuthorizationTest.scala unit/kafka/security/auth/SimpleAclAuthorizerTest.scala unit/kafka/security/auth/ResourceTypeTest.scala unit/kafka/integration/UncleanLeaderElectionTest.scala unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala unit/kafka/integration/KafkaServerTestHarness.scala unit/kafka/integration/MinIsrConfigTest.scala unit/kafka/network/SocketServerTest.scala unit/kafka/admin/PreferredReplicaLeaderElectionCommandTest.scala unit/kafka/admin/AdminRackAwareTest.scala unit/kafka/admin/AdminTest.scala unit/kafka/admin/DescribeConsumerGroupTest.scala unit/kafka/admin/TopicCommandWithAdminClientTest.scala unit/kafka/admin/DeleteTopicTest.scala unit/kafka/admin/RackAwareTest.scala unit/kafka/admin/ListConsumerGroupTest.scala unit/kafka/admin/TestAdminUtils.scala unit/kafka/admin/PreferredReplicaElectionCommandTest.scala unit/kafka/admin/ReplicationQuotaUtils.scala unit/kafka/admin/TopicCommandTest.scala unit/kafka/admin/ConfigCommandTest.scala unit/kafka/admin/AclCommandTest.scala unit/kafka/admin/ConsumerGroupCommandTest.scala unit/kafka/admin/DelegationTokenCommandTest.scala unit/kafka/admin/ResetConsumerGroupOffsetTest.scala unit/kafka/admin/ReassignPartitionsCommandArgsTest.scala unit/kafka/admin/ReassignPartitionsClusterTest.scala unit/kafka/admin/AddPartitionsTest.scala unit/kafka/admin/DeleteConsumerGroupsTest.scala unit/kafka/admin/ReassignPartitionsCommandTest.scala unit/kafka/server/LeaderElectionTest.scala unit/kafka/server/ServerGenerateBrokerIdTest.scala unit/kafka/server/RequestQuotaTest.scala unit/kafka/server/ReplicationQuotaManagerTest.scala unit/kafka/server/ClientQuotaManagerTest.scala unit/kafka/server/KafkaServerTest.scala unit/kafka/server/AdvertiseBrokerTest.scala unit/kafka/server/ISRExpirationTest.scala unit/kafka/server/KafkaMetricReporterClusterIdTest.scala unit/kafka/server/ServerStartupTest.scala unit/kafka/server/DynamicConfigChangeTest.scala unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala unit/kafka/server/ServerShutdownTest.scala unit/kafka/server/ApiVersionsRequestTest.scala unit/kafka/server/HighwatermarkPersistenceTest.scala unit/kafka/server/AddPartitionsToTxnRequestTest.scala unit/kafka/server/ReplicationQuotasTest.scala unit/kafka/server/MetadataCacheTest.scala unit/kafka/server/KafkaApisTest.scala unit/kafka/server/ServerMetricsTest.scala unit/kafka/server/epoch/EpochDrivenReplicationProtocolAcceptanceTest.scala unit/kafka/server/epoch/util/ReplicaFetcherMockBlockingSend.scala unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala unit/kafka/server/epoch/LeaderEpochIntegrationTest.scala unit/kafka/server/epoch/OffsetsForLeaderEpochTest.scala unit/kafka/server/OffsetsForLeaderEpochRequestTest.scala unit/kafka/server/checkpoints/LeaderEpochCheckpointFileTest.scala unit/kafka/server/checkpoints/OffsetCheckpointFileTest.scala unit/kafka/server/StopReplicaRequestTest.scala unit/kafka/server/DelegationTokenRequestsTest.scala unit/kafka/server/ServerGenerateClusterIdTest.scala unit/kafka/server/AbstractCreateTopicsRequestTest.scala unit/kafka/server/LogDirFailureTest.scala unit/kafka/server/FetchRequestDownConversionConfigTest.scala unit/kafka/server/AlterReplicaLogDirsRequestTest.scala unit/kafka/server/ReplicaFetcherThreadTest.scala unit/kafka/server/ThrottledChannelExpirationTest.scala unit/kafka/server/ListOffsetsRequestTest.scala unit/kafka/server/KafkaMetricReporterExceptionHandlingTest.scala unit/kafka/server/FetchSessionTest.scala unit/kafka/server/LogRecoveryTest.scala unit/kafka/server/ReplicaFetchTest.scala unit/kafka/server/BaseRequestTest.scala unit/kafka/server/ProduceRequestTest.scala unit/kafka/server/DynamicBrokerConfigTest.scala unit/kafka/server/LogOffsetTest.scala unit/kafka/server/EdgeCaseRequestTest.scala unit/kafka/server/DeleteTopicsRequestTest.scala unit/kafka/server/MetadataRequestTest.scala unit/kafka/server/ReplicaManagerTest.scala unit/kafka/server/DelegationTokenRequestsWithDisableTokenFeatureTest.scala unit/kafka/server/CreateTopicsRequestWithPolicyTest.scala unit/kafka/server/AbstractFetcherThreadTest.scala unit/kafka/server/DelegationTokenRequestsOnPlainTextTest.scala unit/kafka/server/DelayedOperationTest.scala unit/kafka/server/DynamicConfigTest.scala unit/kafka/server/DeleteTopicsRequestWithDeletionDisabledTest.scala unit/kafka/server/ReplicaManagerQuotasTest.scala unit/kafka/server/AbstractFetcherManagerTest.scala unit/kafka/server/SaslApiVersionsRequestTest.scala unit/kafka/server/CreateTopicsRequestTest.scala unit/kafka/server/BrokerEpochIntegrationTest.scala unit/kafka/server/FetchRequestTest.scala unit/kafka/server/SimpleFetchTest.scala unit/kafka/server/DescribeLogDirsRequestTest.scala unit/kafka/server/KafkaConfigTest.scala unit/kafka/utils/PasswordEncoderTest.scala unit/kafka/utils/CoreUtilsTest.scala unit/kafka/utils/ZkUtilsTest.scala unit/kafka/utils/ReplicationUtilsTest.scala unit/kafka/utils/timer/TimerTaskListTest.scala unit/kafka/utils/timer/MockTimer.scala unit/kafka/utils/timer/TimerTest.scala unit/kafka/utils/TopicFilterTest.scala unit/kafka/utils/CommandLineUtilsTest.scala unit/kafka/utils/ThrottlerTest.scala unit/kafka/utils/json/JsonValueTest.scala unit/kafka/utils/SchedulerTest.scala unit/kafka/utils/ShutdownableThreadTest.scala unit/kafka/utils/JsonTest.scala unit/kafka/utils/JaasTestUtils.scala unit/kafka/utils/LogCaptureAppender.scala unit/kafka/utils/MockScheduler.scala unit/kafka/utils/MockTime.scala unit/kafka/utils/TestUtils.scala unit/kafka/zookeeper/ZooKeeperClientTest.scala unit/kafka/controller/MockPartitionStateMachine.scala unit/kafka/controller/TopicDeletionManagerTest.scala unit/kafka/controller/ControllerFailoverTest.scala unit/kafka/controller/ReplicaStateMachineTest.scala unit/kafka/controller/PartitionStateMachineTest.scala unit/kafka/controller/MockReplicaStateMachine.scala unit/kafka/controller/PartitionLeaderElectionAlgorithmsTest.scala unit/kafka/controller/ControllerIntegrationTest.scala unit/kafka/controller/ControllerChannelManagerTest.scala unit/kafka/controller/ControllerEventManagerTest.scala unit/kafka/common/ZkNodeChangeNotificationListenerTest.scala unit/kafka/api/ApiUtilsTest.scala unit/kafka/api/ApiVersionTest.scala unit/kafka/log/OffsetMapTest.scala unit/kafka/log/TimeIndexTest.scala unit/kafka/log/LogSegmentTest.scala unit/kafka/log/LogCleanerParameterizedIntegrationTest.scala unit/kafka/log/LogCleanerIntegrationTest.scala unit/kafka/log/LogValidatorTest.scala unit/kafka/log/LogCleanerManagerTest.scala unit/kafka/log/OffsetIndexTest.scala unit/kafka/log/LogUtils.scala unit/kafka/log/LogCleanerTest.scala unit/kafka/log/BrokerCompressionTest.scala unit/kafka/log/TransactionIndexTest.scala unit/kafka/log/LogCleanerLagIntegrationTest.scala unit/kafka/log/LogTest.scala unit/kafka/log/AbstractLogCleanerIntegrationTest.scala unit/kafka/log/ProducerStateManagerTest.scala unit/kafka/log/LogConfigTest.scala unit/kafka/log/LogManagerTest.scala unit/kafka/KafkaConfigTest.scala integration/kafka/tools/MirrorMakerIntegrationTest.scala integration/kafka/network/DynamicConnectionQuotaTest.scala integration/kafka/admin/BrokerApiVersionsCommandTest.scala integration/kafka/admin/ReassignPartitionsIntegrationTest.scala integration/kafka/server/DynamicBrokerReconfigurationTest.scala integration/kafka/server/MultipleListenersWithAdditionalJaasContextTest.scala integration/kafka/server/GssapiAuthenticationTest.scala integration/kafka/server/DelayedFetchTest.scala integration/kafka/server/MultipleListenersWithSameSecurityProtocolBaseTest.scala integration/kafka/server/ScramServerStartupTest.scala integration/kafka/server/MultipleListenersWithDefaultJaasContextTest.scala integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala integration/kafka/api/SaslSslAdminClientIntegrationTest.scala integration/kafka/api/SaslPlaintextConsumerTest.scala integration/kafka/api/EndToEndClusterIdTest.scala integration/kafka/api/BaseProducerSendTest.scala integration/kafka/api/UserClientIdQuotaTest.scala integration/kafka/api/AbstractConsumerTest.scala integration/kafka/api/GroupCoordinatorIntegrationTest.scala integration/kafka/api/MetricsTest.scala integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala integration/kafka/api/GroupAuthorizerIntegrationTest.scala integration/kafka/api/TransactionsBounceTest.scala #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	无