kafka-clients-2.3.0-test-sources.jar

<dependency>
	<groupId>org.apache.kafka</groupId>
	<artifactId>kafka-clients</artifactId>
	<version>2.3.0</version>
</dependency>

org.apache.kafka:kafka-clients:2.3.0

META-INF/MANIFEST.MF
LICENSE
NOTICE
serializedData/offsetAndMetadataWithLeaderEpoch
serializedData/topicPartitionSerializedfile
serializedData/offsetAndMetadataBeforeLeaderEpoch
log4j.properties
org/apache/kafka/common/message/JoinGroupRequestData.java
org/apache/kafka/common/message/DeleteGroupsRequestData.java
org/apache/kafka/common/message/ProduceRequestData.java
org/apache/kafka/common/message/CreatePartitionsResponseData.java
org/apache/kafka/common/message/SaslHandshakeRequestData.java
org/apache/kafka/common/message/OffsetFetchRequestData.java
org/apache/kafka/common/message/DeleteAclsRequestData.java
org/apache/kafka/common/message/ExpireDelegationTokenResponseData.java
org/apache/kafka/common/message/AlterReplicaLogDirsRequestData.java
org/apache/kafka/common/message/OffsetFetchResponseData.java
org/apache/kafka/common/message/AddOffsetsToTxnRequestData.java
org/apache/kafka/common/message/DescribeLogDirsResponseData.java
org/apache/kafka/common/message/UpdateMetadataResponseData.java
org/apache/kafka/common/message/CreateTopicsResponseData.java
org/apache/kafka/common/message/AddPartitionsToTxnResponseData.java
org/apache/kafka/common/message/DeleteGroupsResponseData.java
org/apache/kafka/common/message/FetchRequestData.java
org/apache/kafka/common/message/ElectPreferredLeadersResponseData.java
org/apache/kafka/common/message/DescribeGroupsResponseData.java
org/apache/kafka/common/message/RequestHeaderData.java
org/apache/kafka/common/message/CreateDelegationTokenResponseData.java
org/apache/kafka/common/message/ApiVersionsRequestData.java
org/apache/kafka/common/message/OffsetCommitResponseData.java
org/apache/kafka/common/message/LeaveGroupRequestData.java
org/apache/kafka/common/message/ApiMessageType.java
org/apache/kafka/common/message/DeleteRecordsRequestData.java
org/apache/kafka/common/message/DescribeDelegationTokenResponseData.java
org/apache/kafka/common/message/IncrementalAlterConfigsRequestData.java
org/apache/kafka/common/message/LeaveGroupResponseData.java
org/apache/kafka/common/message/RenewDelegationTokenResponseData.java
org/apache/kafka/common/message/LeaderAndIsrResponseData.java
org/apache/kafka/common/message/HeartbeatResponseData.java
org/apache/kafka/common/message/EndTxnResponseData.java
org/apache/kafka/common/message/WriteTxnMarkersRequestData.java
org/apache/kafka/common/message/TxnOffsetCommitResponseData.java
org/apache/kafka/common/message/DeleteTopicsRequestData.java
org/apache/kafka/common/message/StopReplicaResponseData.java
org/apache/kafka/common/message/DescribeAclsRequestData.java
org/apache/kafka/common/message/OffsetForLeaderEpochRequestData.java
org/apache/kafka/common/message/IncrementalAlterConfigsResponseData.java
org/apache/kafka/common/message/SaslAuthenticateRequestData.java
org/apache/kafka/common/message/InitProducerIdResponseData.java
org/apache/kafka/common/message/CreateTopicsRequestData.java
org/apache/kafka/common/message/EndTxnRequestData.java
org/apache/kafka/common/message/OffsetCommitRequestData.java
org/apache/kafka/common/message/DescribeGroupsRequestData.java
org/apache/kafka/common/message/ResponseHeaderData.java
org/apache/kafka/common/message/ListOffsetRequestData.java
org/apache/kafka/common/message/ElectPreferredLeadersRequestData.java
org/apache/kafka/common/message/ProduceResponseData.java
org/apache/kafka/common/message/CreateAclsResponseData.java
org/apache/kafka/common/message/UpdateMetadataRequestData.java
org/apache/kafka/common/message/ControlledShutdownResponseData.java
org/apache/kafka/common/message/DescribeDelegationTokenRequestData.java
org/apache/kafka/common/message/MetadataResponseData.java
org/apache/kafka/common/message/AlterReplicaLogDirsResponseData.java
org/apache/kafka/common/message/JoinGroupResponseData.java
org/apache/kafka/common/message/StopReplicaRequestData.java
org/apache/kafka/common/message/TxnOffsetCommitRequestData.java
org/apache/kafka/common/message/InitProducerIdRequestData.java
org/apache/kafka/common/message/CreateAclsRequestData.java
org/apache/kafka/common/message/LeaderAndIsrRequestData.java
org/apache/kafka/common/message/SaslAuthenticateResponseData.java
org/apache/kafka/common/message/SyncGroupRequestData.java
org/apache/kafka/common/message/SyncGroupResponseData.java
org/apache/kafka/common/message/FindCoordinatorRequestData.java
org/apache/kafka/common/message/ListGroupsResponseData.java
org/apache/kafka/common/message/DescribeAclsResponseData.java
org/apache/kafka/common/message/ExpireDelegationTokenRequestData.java
org/apache/kafka/common/message/DeleteAclsResponseData.java
org/apache/kafka/common/message/CreatePartitionsRequestData.java
org/apache/kafka/common/message/AddPartitionsToTxnRequestData.java
org/apache/kafka/common/message/AlterConfigsRequestData.java
org/apache/kafka/common/message/AlterConfigsResponseData.java
org/apache/kafka/common/message/FetchResponseData.java
org/apache/kafka/common/message/FindCoordinatorResponseData.java
org/apache/kafka/common/message/DeleteTopicsResponseData.java
org/apache/kafka/common/message/SaslHandshakeResponseData.java
org/apache/kafka/common/message/MetadataRequestData.java
org/apache/kafka/common/message/OffsetForLeaderEpochResponseData.java
org/apache/kafka/common/message/ListOffsetResponseData.java
org/apache/kafka/common/message/RenewDelegationTokenRequestData.java
org/apache/kafka/common/message/ListGroupsRequestData.java
org/apache/kafka/common/message/HeartbeatRequestData.java
org/apache/kafka/common/message/WriteTxnMarkersResponseData.java
org/apache/kafka/common/message/ControlledShutdownRequestData.java
org/apache/kafka/common/message/DescribeConfigsRequestData.java
org/apache/kafka/common/message/CreateDelegationTokenRequestData.java
org/apache/kafka/common/message/DescribeLogDirsRequestData.java
org/apache/kafka/common/message/DescribeConfigsResponseData.java
org/apache/kafka/common/message/AddOffsetsToTxnResponseData.java
org/apache/kafka/common/message/DeleteRecordsResponseData.java
org/apache/kafka/common/message/ApiVersionsResponseData.java
org/apache/kafka/common/memory/GarbageCollectedMemoryPoolTest.java
org/apache/kafka/common/header/internals/RecordHeadersTest.java
org/apache/kafka/common/message/ApiMessageTypeTest.java
org/apache/kafka/common/message/MessageTest.java
org/apache/kafka/common/internals/PartitionStatesTest.java
org/apache/kafka/common/internals/TopicTest.java
org/apache/kafka/common/protocol/types/StructTest.java
org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java
org/apache/kafka/common/protocol/ProtoUtilsTest.java
org/apache/kafka/common/protocol/MessageUtilTest.java
org/apache/kafka/common/protocol/ErrorsTest.java
org/apache/kafka/common/protocol/ApiKeysTest.java
org/apache/kafka/common/resource/ResourceTypeTest.java
org/apache/kafka/common/resource/ResourceFilterTest.java
org/apache/kafka/common/network/ChannelBuildersTest.java
org/apache/kafka/common/network/NetworkTestUtils.java
org/apache/kafka/common/network/SelectorTest.java
org/apache/kafka/common/network/SslTransportLayerTest.java
org/apache/kafka/common/network/NioEchoServer.java
org/apache/kafka/common/network/PlaintextSender.java
org/apache/kafka/common/network/SslSender.java
org/apache/kafka/common/network/SaslChannelBuilderTest.java
org/apache/kafka/common/network/EchoServer.java
org/apache/kafka/common/network/SslSelectorTest.java
org/apache/kafka/common/network/CertStores.java
org/apache/kafka/common/record/ControlRecordTypeTest.java
org/apache/kafka/common/record/MultiRecordsSendTest.java
org/apache/kafka/common/record/MemoryRecordsTest.java
org/apache/kafka/common/record/KafkaLZ4Test.java
org/apache/kafka/common/record/SimpleMemoryRecordsTest.java
org/apache/kafka/common/record/SimpleLegacyRecordTest.java
org/apache/kafka/common/record/DefaultRecordBatchTest.java
org/apache/kafka/common/record/DefaultRecordTest.java
org/apache/kafka/common/record/LazyDownConversionRecordsTest.java
org/apache/kafka/common/record/EndTransactionMarkerTest.java
org/apache/kafka/common/record/FileLogInputStreamTest.java
org/apache/kafka/common/record/ByteBufferLogInputStreamTest.java
org/apache/kafka/common/record/BufferSupplierTest.java
org/apache/kafka/common/record/CompressionTypeTest.java
org/apache/kafka/common/record/AbstractLegacyRecordBatchTest.java
org/apache/kafka/common/record/FileRecordsTest.java
org/apache/kafka/common/record/MemoryRecordsBuilderTest.java
org/apache/kafka/common/record/LegacyRecordTest.java
org/apache/kafka/common/PartitionInfoTest.java
org/apache/kafka/common/utils/Crc32Test.java
org/apache/kafka/common/utils/AbstractIteratorTest.java
org/apache/kafka/common/utils/Crc32CTest.java
org/apache/kafka/common/utils/MockTime.java
org/apache/kafka/common/utils/MockTimeTest.java
org/apache/kafka/common/utils/MappedByteBuffersTest.java
org/apache/kafka/common/utils/SanitizerTest.java
org/apache/kafka/common/utils/ByteUtilsTest.java
org/apache/kafka/common/utils/SecurityUtilsTest.java
org/apache/kafka/common/utils/UtilsTest.java
org/apache/kafka/common/utils/TimerTest.java
org/apache/kafka/common/utils/MockScheduler.java
org/apache/kafka/common/utils/LoggingSignalHandlerTest.java
org/apache/kafka/common/utils/SystemTimeTest.java
org/apache/kafka/common/utils/ShellTest.java
org/apache/kafka/common/utils/JavaTest.java
org/apache/kafka/common/utils/ImplicitLinkedHashCollectionTest.java
org/apache/kafka/common/utils/ImplicitLinkedHashMultiCollectionTest.java
org/apache/kafka/common/utils/CollectionUtilsTest.java
org/apache/kafka/common/utils/TimeTest.java
org/apache/kafka/common/utils/ByteBufferOutputStreamTest.java
org/apache/kafka/common/utils/Serializer.java
org/apache/kafka/common/utils/AppInfoParserTest.java
org/apache/kafka/common/utils/ChecksumsTest.java
org/apache/kafka/common/utils/FixedOrderMapTest.java
org/apache/kafka/common/metrics/JmxReporterTest.java
org/apache/kafka/common/metrics/SampleMetrics.java
org/apache/kafka/common/metrics/FakeMetricsReporter.java
org/apache/kafka/common/metrics/MetricsTest.java
org/apache/kafka/common/metrics/SensorTest.java
org/apache/kafka/common/metrics/KafkaMbeanTest.java
org/apache/kafka/common/metrics/stats/HistogramTest.java
org/apache/kafka/common/metrics/stats/FrequenciesTest.java
org/apache/kafka/common/metrics/stats/MeterTest.java
org/apache/kafka/common/KafkaFutureTest.java
org/apache/kafka/common/cache/LRUCacheTest.java
org/apache/kafka/common/serialization/SerializationTest.java
org/apache/kafka/common/security/authenticator/TestJaasConfig.java
org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java
org/apache/kafka/common/security/authenticator/SaslServerAuthenticatorTest.java
org/apache/kafka/common/security/authenticator/SaslAuthenticatorFailureDelayTest.java
org/apache/kafka/common/security/authenticator/LoginManagerTest.java
org/apache/kafka/common/security/authenticator/TestDigestLoginModule.java
org/apache/kafka/common/security/authenticator/ClientAuthenticationFailureTest.java
org/apache/kafka/common/security/kerberos/KerberosRuleTest.java
org/apache/kafka/common/security/kerberos/KerberosNameTest.java
org/apache/kafka/common/security/scram/internals/ScramMessagesTest.java
org/apache/kafka/common/security/scram/internals/ScramFormatterTest.java
org/apache/kafka/common/security/scram/internals/ScramCredentialUtilsTest.java
org/apache/kafka/common/security/scram/internals/ScramSaslServerTest.java
org/apache/kafka/common/security/ssl/SslPrincipalMapperTest.java
org/apache/kafka/common/security/ssl/SslFactoryTest.java
org/apache/kafka/common/security/ssl/mock/TestKeyManagerFactory.java
org/apache/kafka/common/security/ssl/mock/TestProvider.java
org/apache/kafka/common/security/ssl/mock/TestTrustManagerFactory.java
org/apache/kafka/common/security/JaasContextTest.java
org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerClientInitialResponseTest.java
org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslServerTest.java
org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshConfigTest.java
org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshingLoginTest.java
org/apache/kafka/common/security/oauthbearer/internals/OAuthBearerSaslClientTest.java
org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerValidationUtilsTest.java
org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerScopeUtilsTest.java
org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredLoginCallbackHandlerTest.java
org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredValidatorCallbackHandlerTest.java
org/apache/kafka/common/security/oauthbearer/internals/unsecured/OAuthBearerUnsecuredJwsTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerExtensionsValidatorCallbackTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginModuleTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenCallbackTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerSaslClienCallbackHandlerTest.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenMock.java
org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallbackTest.java
org/apache/kafka/common/security/auth/KafkaPrincipalTest.java
org/apache/kafka/common/security/auth/DefaultKafkaPrincipalBuilderTest.java
org/apache/kafka/common/security/SaslExtensionsTest.java
org/apache/kafka/common/security/plain/internals/PlainSaslServerTest.java
org/apache/kafka/common/security/TestSecurityConfig.java
org/apache/kafka/common/acl/ResourcePatternFilterTest.java
org/apache/kafka/common/acl/AclOperationTest.java
org/apache/kafka/common/acl/AclPermissionTypeTest.java
org/apache/kafka/common/acl/ResourcePatternTest.java
org/apache/kafka/common/acl/AclBindingTest.java
org/apache/kafka/common/config/ConfigDefTest.java
org/apache/kafka/common/config/AbstractConfigTest.java
org/apache/kafka/common/config/SaslConfigsTest.java
org/apache/kafka/common/config/ConfigResourceTest.java
org/apache/kafka/common/config/provider/FileConfigProviderTest.java
org/apache/kafka/common/config/provider/MockFileConfigProvider.java
org/apache/kafka/common/config/provider/MockVaultConfigProvider.java
org/apache/kafka/common/config/ConfigTransformerTest.java
org/apache/kafka/common/TopicPartitionTest.java
org/apache/kafka/common/requests/RequestResponseTest.java
org/apache/kafka/common/requests/DescribeAclsResponseTest.java
org/apache/kafka/common/requests/RequestHeaderTest.java
org/apache/kafka/common/requests/SyncGroupRequestTest.java
org/apache/kafka/common/requests/OffsetsForLeaderEpochRequestTest.java
org/apache/kafka/common/requests/HeartbeatRequestTest.java
org/apache/kafka/common/requests/RequestContextTest.java
org/apache/kafka/common/requests/JoinGroupRequestTest.java
org/apache/kafka/common/requests/DeleteAclsRequestTest.java
org/apache/kafka/common/requests/MetadataRequestTest.java
org/apache/kafka/common/requests/OffsetCommitRequestTest.java
org/apache/kafka/common/requests/StopReplicaResponseTest.java
org/apache/kafka/common/requests/CreateAclsRequestTest.java
org/apache/kafka/common/requests/DeleteAclsResponseTest.java
org/apache/kafka/common/requests/ByteBufferChannel.java
org/apache/kafka/common/requests/LeaderAndIsrResponseTest.java
org/apache/kafka/common/requests/ProduceRequestTest.java
org/apache/kafka/common/requests/ControlRequestTest.java
org/apache/kafka/common/requests/DescribeAclsRequestTest.java
#内容未全部加载，请点击展开加载全部代码(NowJava.com)