登录注册

Jar文件详情内容

kafka-clients-1.1.1.jar

所在目录：/org/apache/kafka/kafka-clients/1.1.1 查看kafka-clients所有版本文件

组织ID:	org.apache.kafka
项目ID:	kafka-clients
版本:	1.1.1
最后修改时间:	2018-07-25 12:52:15
包类型:	jar
标题:	Apache Kafka
相关URL:	http://kafka.apache.org
大小:	1.64MB

Maven引入代码:	`<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>1.1.1</version> </dependency>`
Gradle引入代码:	`org.apache.kafka:kafka-clients:1.1.1`
下载Jar包:	kafka-clients-1.1.1.jar
POM文件内容:	展开复制 <?xml version="1.0" encoding="UTF-8"?> <project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> <modelVersion>4.0.0</modelVersion> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>1.1.1</version> <name>Apache Kafka</name> <url>http://kafka.apache.org</url> <licenses> <license> <name>The Apache Software License, Version 2.0</name> <url>http://www.apache.org/licenses/LICENSE-2.0.txt</url> <distribution>repo</distribution> </license> </licenses> <dependencies> <dependency> <groupId>org.lz4</groupId> <artifactId>lz4-java</artifactId> <version>1.4.1</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.xerial.snappy</groupId> <artifactId>snappy-java</artifactId> <version>1.1.7.1</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.25</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.bouncycastle</groupId> <artifactId>bcpkix-jdk15on</artifactId> <version>1.59</version> <scope>test</scope> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.12</version> <scope>test</scope> </dependency> <dependency> <groupId>org.easymock</groupId> <artifactId>easymock</artifactId> <version>3.6</version> <scope>test</scope> </dependency> <dependency> <groupId>org.powermock</groupId> <artifactId>powermock-module-junit4</artifactId> <version>2.0.0-beta.5</version> <scope>test</scope> </dependency> <dependency> <groupId>org.powermock</groupId> <artifactId>powermock-api-easymock</artifactId> <version>2.0.0-beta.5</version> <scope>test</scope> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.25</version> <scope>test</scope> </dependency> </dependencies> </project>
Jar包内容:	展开复制 META-INF/MANIFEST.MF org.apache.kafka.server.policy.CreateTopicPolicy.class org.apache.kafka.server.policy.CreateTopicPolicy$RequestMetadata.class org.apache.kafka.server.policy.AlterConfigPolicy.class org.apache.kafka.server.policy.AlterConfigPolicy$RequestMetadata.class org.apache.kafka.common.ClusterResourceListener.class org.apache.kafka.common.TopicPartitionInfo.class org.apache.kafka.common.MetricNameTemplate.class org.apache.kafka.common.memory.GarbageCollectedMemoryPool$1.class org.apache.kafka.common.memory.GarbageCollectedMemoryPool$BufferMetadata.class org.apache.kafka.common.memory.MemoryPool.class org.apache.kafka.common.memory.GarbageCollectedMemoryPool$GarbageCollectionListener.class org.apache.kafka.common.memory.SimpleMemoryPool.class org.apache.kafka.common.memory.GarbageCollectedMemoryPool$BufferReference.class org.apache.kafka.common.memory.MemoryPool$1.class org.apache.kafka.common.memory.GarbageCollectedMemoryPool.class org.apache.kafka.common.requests.InitProducerIdRequest.class org.apache.kafka.common.requests.ResourceType.class org.apache.kafka.common.requests.LeaderAndIsrRequest$PartitionState.class org.apache.kafka.common.requests.CreateAclsRequest.class org.apache.kafka.common.requests.TxnOffsetCommitRequest$Builder.class org.apache.kafka.common.requests.FindCoordinatorResponse.class org.apache.kafka.common.requests.ListGroupsResponse$Group.class org.apache.kafka.common.requests.DescribeConfigsResponse$ConfigEntry.class org.apache.kafka.common.requests.SaslHandshakeRequest.class org.apache.kafka.common.requests.CreateDelegationTokenResponse.class org.apache.kafka.common.requests.DeleteTopicsRequest$1.class org.apache.kafka.common.requests.UpdateMetadataRequest$Broker.class org.apache.kafka.common.requests.AbstractResponse$1.class org.apache.kafka.common.requests.ProduceResponse$PartitionResponse.class org.apache.kafka.common.requests.ExpireDelegationTokenRequest$Builder.class org.apache.kafka.common.requests.DeleteGroupsRequest$Builder.class org.apache.kafka.common.requests.AddOffsetsToTxnRequest$Builder.class org.apache.kafka.common.requests.TxnOffsetCommitRequest$CommittedOffset.class org.apache.kafka.common.requests.WriteTxnMarkersRequest$1.class org.apache.kafka.common.requests.DeleteTopicsRequest.class org.apache.kafka.common.requests.AddOffsetsToTxnRequest$1.class org.apache.kafka.common.requests.BasePartitionState.class org.apache.kafka.common.requests.UpdateMetadataRequest$Builder.class org.apache.kafka.common.requests.DescribeAclsResponse.class org.apache.kafka.common.requests.HeartbeatRequest.class org.apache.kafka.common.requests.OffsetCommitRequest$1.class org.apache.kafka.common.requests.FindCoordinatorRequest$Builder.class org.apache.kafka.common.requests.LeaveGroupRequest.class org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata.class org.apache.kafka.common.requests.DescribeConfigsResponse$Config.class org.apache.kafka.common.requests.OffsetFetchRequest$1.class org.apache.kafka.common.requests.DescribeConfigsResponse$1.class org.apache.kafka.common.requests.DeleteRecordsRequest$Builder.class org.apache.kafka.common.requests.CreateAclsResponse.class org.apache.kafka.common.requests.DescribeLogDirsResponse$LogDirInfo.class org.apache.kafka.common.requests.AlterReplicaLogDirsRequest.class org.apache.kafka.common.requests.DescribeGroupsRequest.class org.apache.kafka.common.requests.FetchRequest$Builder.class org.apache.kafka.common.requests.DescribeDelegationTokenResponse.class org.apache.kafka.common.requests.CreatePartitionsRequest$Builder.class org.apache.kafka.common.requests.WriteTxnMarkersResponse.class org.apache.kafka.common.requests.AlterConfigsRequest.class org.apache.kafka.common.requests.HeartbeatRequest$1.class org.apache.kafka.common.requests.DeleteAclsRequest$Builder.class org.apache.kafka.common.requests.DescribeConfigsRequest.class org.apache.kafka.common.requests.CreateDelegationTokenRequest.class org.apache.kafka.common.requests.AbstractRequest$Builder.class org.apache.kafka.common.requests.RenewDelegationTokenRequest$Builder.class org.apache.kafka.common.requests.UpdateMetadataRequest$PartitionState.class org.apache.kafka.common.requests.MetadataResponse.class org.apache.kafka.common.requests.OffsetCommitRequest.class org.apache.kafka.common.requests.MetadataRequest.class org.apache.kafka.common.requests.TransactionResult.class org.apache.kafka.common.requests.ListOffsetRequest.class org.apache.kafka.common.requests.ExpireDelegationTokenRequest$1.class org.apache.kafka.common.requests.LeaderAndIsrRequest.class org.apache.kafka.common.requests.SyncGroupResponse.class org.apache.kafka.common.requests.DeleteTopicsResponse.class org.apache.kafka.common.requests.DescribeLogDirsResponse.class org.apache.kafka.common.requests.AddPartitionsToTxnRequest$Builder.class org.apache.kafka.common.requests.RequestUtils.class org.apache.kafka.common.requests.SaslAuthenticateResponse.class org.apache.kafka.common.requests.DescribeAclsRequest.class org.apache.kafka.common.requests.InitProducerIdResponse.class org.apache.kafka.common.requests.TxnOffsetCommitRequest.class org.apache.kafka.common.requests.TxnOffsetCommitResponse.class org.apache.kafka.common.requests.OffsetFetchResponse.class org.apache.kafka.common.requests.DescribeConfigsRequest$Builder.class org.apache.kafka.common.requests.CreateAclsRequest$AclCreation.class org.apache.kafka.common.requests.CreatePartitionsRequest.class org.apache.kafka.common.requests.LeaderAndIsrResponse.class org.apache.kafka.common.requests.SyncGroupRequest$1.class org.apache.kafka.common.requests.StopReplicaRequest.class org.apache.kafka.common.requests.ListOffsetResponse$PartitionData.class org.apache.kafka.common.requests.CreateTopicsRequest$TopicDetails.class org.apache.kafka.common.requests.CreateTopicsResponse.class org.apache.kafka.common.requests.ExpireDelegationTokenResponse.class org.apache.kafka.common.requests.CreatePartitionsResponse.class org.apache.kafka.common.requests.CreateAclsRequest$Builder.class org.apache.kafka.common.requests.ResponseHeader.class org.apache.kafka.common.requests.AddOffsetsToTxnRequest.class org.apache.kafka.common.requests.StopReplicaResponse.class org.apache.kafka.common.requests.IsolationLevel.class org.apache.kafka.common.requests.SyncGroupRequest.class org.apache.kafka.common.requests.AddPartitionsToTxnRequest.class org.apache.kafka.common.requests.AbstractRequest$1.class org.apache.kafka.common.requests.AlterReplicaLogDirsRequest$Builder.class org.apache.kafka.common.requests.FindCoordinatorRequest.class org.apache.kafka.common.requests.SaslHandshakeRequest$Builder.class org.apache.kafka.common.requests.OffsetCommitRequest$PartitionData.class org.apache.kafka.common.requests.AlterReplicaLogDirsResponse.class org.apache.kafka.common.requests.ControlledShutdownRequest$1.class org.apache.kafka.common.requests.SaslHandshakeResponse.class org.apache.kafka.common.requests.InitProducerIdRequest$1.class org.apache.kafka.common.requests.DescribeConfigsResponse$ConfigSource.class org.apache.kafka.common.requests.ExpireDelegationTokenRequest.class org.apache.kafka.common.requests.HeartbeatRequest$Builder.class org.apache.kafka.common.requests.CreateDelegationTokenRequest$1.class org.apache.kafka.common.requests.DeleteGroupsRequest$1.class org.apache.kafka.common.requests.RenewDelegationTokenRequest$1.class org.apache.kafka.common.requests.DescribeDelegationTokenRequest$1.class org.apache.kafka.common.requests.JoinGroupRequest$Builder.class org.apache.kafka.common.requests.AbstractResponse.class org.apache.kafka.common.requests.CreateTopicsRequest$Builder.class org.apache.kafka.common.requests.FindCoordinatorRequest$1.class org.apache.kafka.common.requests.DeleteRecordsResponse.class org.apache.kafka.common.requests.OffsetCommitResponse.class org.apache.kafka.common.requests.ApiVersionsRequest$Builder.class org.apache.kafka.common.requests.CreateDelegationTokenRequest$Builder.class org.apache.kafka.common.requests.RecordsSend.class org.apache.kafka.common.requests.DeleteAclsResponse.class org.apache.kafka.common.requests.FetchResponse.class org.apache.kafka.common.requests.LeaderAndIsrRequest$1.class org.apache.kafka.common.requests.EndTxnResponse.class org.apache.kafka.common.requests.ApiVersionsResponse.class org.apache.kafka.common.requests.OffsetsForLeaderEpochRequest$Builder.class org.apache.kafka.common.requests.RenewDelegationTokenResponse.class org.apache.kafka.common.requests.OffsetCommitRequest$Builder.class org.apache.kafka.common.requests.FetchRequest$PartitionData.class org.apache.kafka.common.requests.ListGroupsRequest$Builder.class org.apache.kafka.common.requests.DescribeConfigsResponse.class org.apache.kafka.common.requests.WriteTxnMarkersRequest$TxnMarkerEntry.class org.apache.kafka.common.requests.SaslAuthenticateRequest.class org.apache.kafka.common.requests.DescribeGroupsResponse$GroupMetadata.class org.apache.kafka.common.requests.ListOffsetRequest$1.class org.apache.kafka.common.requests.UpdateMetadataRequest$EndPoint.class org.apache.kafka.common.requests.JoinGroupRequest$1.class org.apache.kafka.common.requests.AbstractRequestResponse.class org.apache.kafka.common.requests.DescribeAclsRequest$Builder.class org.apache.kafka.common.requests.Resource.class org.apache.kafka.common.requests.RequestAndSize.class org.apache.kafka.common.requests.LeaveGroupResponse.class org.apache.kafka.common.requests.StopReplicaRequest$Builder.class org.apache.kafka.common.requests.FetchRequest$TopicAndPartitionData.class org.apache.kafka.common.requests.LeaveGroupRequest$Builder.class org.apache.kafka.common.requests.UpdateMetadataResponse.class org.apache.kafka.common.requests.ProduceResponse.class org.apache.kafka.common.requests.WriteTxnMarkersRequest$Builder.class org.apache.kafka.common.requests.EpochEndOffset.class org.apache.kafka.common.requests.DeleteGroupsResponse.class org.apache.kafka.common.requests.OffsetFetchRequest$Builder.class org.apache.kafka.common.requests.ControlledShutdownResponse.class org.apache.kafka.common.requests.ControlledShutdownRequest.class org.apache.kafka.common.requests.FetchResponse$PartitionData.class org.apache.kafka.common.requests.EndTxnRequest.class org.apache.kafka.common.requests.HeartbeatResponse.class org.apache.kafka.common.requests.SaslAuthenticateRequest$Builder.class org.apache.kafka.common.requests.UpdateMetadataRequest$1.class org.apache.kafka.common.requests.FetchResponse$AbortedTransaction.class org.apache.kafka.common.requests.ControlledShutdownRequest$Builder.class org.apache.kafka.common.requests.FetchMetadata.class org.apache.kafka.common.requests.DescribeConfigsResponse$ConfigSynonym.class org.apache.kafka.common.requests.DescribeLogDirsRequest.class org.apache.kafka.common.requests.AddOffsetsToTxnResponse.class org.apache.kafka.common.requests.RenewDelegationTokenRequest.class org.apache.kafka.common.requests.LeaveGroupRequest$1.class org.apache.kafka.common.requests.AlterConfigsRequest$ConfigEntry.class org.apache.kafka.common.requests.DeleteAclsResponse$AclFilterResponse.class org.apache.kafka.common.requests.ListGroupsResponse.class org.apache.kafka.common.requests.DeleteAclsResponse$AclDeletionResult.class org.apache.kafka.common.requests.LeaderAndIsrRequest$Builder.class org.apache.kafka.common.requests.FetchRequest$1.class org.apache.kafka.common.requests.CreateTopicsRequest$1.class org.apache.kafka.common.requests.DeleteRecordsRequest.class org.apache.kafka.common.requests.RequestContext.class org.apache.kafka.common.requests.AddPartitionsToTxnRequest$1.class org.apache.kafka.common.requests.RequestHeader.class org.apache.kafka.common.requests.MetadataResponse$PartitionMetadata.class org.apache.kafka.common.requests.MetadataRequest$Builder.class org.apache.kafka.common.requests.SyncGroupRequest$Builder.class org.apache.kafka.common.requests.DeleteRecordsResponse$PartitionResponse.class org.apache.kafka.common.requests.CreateTopicsRequest.class org.apache.kafka.common.requests.DeleteAclsRequest.class org.apache.kafka.common.requests.ApiVersionsResponse$ApiVersion.class org.apache.kafka.common.requests.MetadataResponse$TopicMetadata.class org.apache.kafka.common.requests.OffsetFetchResponse$PartitionData.class org.apache.kafka.common.requests.OffsetsForLeaderEpochResponse.class org.apache.kafka.common.requests.EndTxnRequest$Builder.class org.apache.kafka.common.requests.ProduceRequest.class org.apache.kafka.common.requests.DeleteGroupsRequest.class org.apache.kafka.common.requests.AlterConfigsRequest$Builder.class org.apache.kafka.common.requests.OffsetFetchRequest.class org.apache.kafka.common.requests.DescribeGroupsResponse$GroupMember.class org.apache.kafka.common.requests.AlterConfigsResponse.class org.apache.kafka.common.requests.JoinGroupRequest.class org.apache.kafka.common.requests.AbstractRequest.class org.apache.kafka.common.requests.EndTxnRequest$1.class org.apache.kafka.common.requests.WriteTxnMarkersRequest.class org.apache.kafka.common.requests.DeleteTopicsRequest$Builder.class org.apache.kafka.common.requests.AlterConfigsRequest$Config.class org.apache.kafka.common.requests.DescribeGroupsRequest$Builder.class org.apache.kafka.common.requests.FindCoordinatorRequest$CoordinatorType.class org.apache.kafka.common.requests.DescribeLogDirsRequest$Builder.class org.apache.kafka.common.requests.DescribeGroupsResponse.class org.apache.kafka.common.requests.StopReplicaRequest$1.class org.apache.kafka.common.requests.ListGroupsRequest.class org.apache.kafka.common.requests.ApiVersionsRequest.class org.apache.kafka.common.requests.ApiError.class org.apache.kafka.common.requests.ProduceRequest$Builder.class org.apache.kafka.common.requests.AddPartitionsToTxnResponse.class org.apache.kafka.common.requests.CreateAclsResponse$AclCreationResponse.class org.apache.kafka.common.requests.ListOffsetRequest$Builder.class org.apache.kafka.common.requests.UpdateMetadataRequest.class org.apache.kafka.common.requests.ProduceRequest$1.class org.apache.kafka.common.requests.OffsetsForLeaderEpochRequest.class org.apache.kafka.common.requests.DescribeDelegationTokenRequest$Builder.class org.apache.kafka.common.requests.InitProducerIdRequest$Builder.class org.apache.kafka.common.requests.ListOffsetResponse.class org.apache.kafka.common.requests.DescribeLogDirsResponse$ReplicaInfo.class org.apache.kafka.common.requests.ListOffsetRequest$PartitionData.class org.apache.kafka.common.requests.JoinGroupResponse.class org.apache.kafka.common.requests.FetchRequest.class org.apache.kafka.common.requests.DescribeDelegationTokenRequest.class org.apache.kafka.common.requests.DescribeGroupsRequest$1.class org.apache.kafka.common.protocol.ApiKeys$1.class org.apache.kafka.common.protocol.Errors$13.class org.apache.kafka.common.protocol.Errors$23.class org.apache.kafka.common.protocol.Errors$70.class org.apache.kafka.common.protocol.Errors$21.class org.apache.kafka.common.protocol.Errors$1.class org.apache.kafka.common.protocol.Protocol.class org.apache.kafka.common.protocol.types.Type$6.class org.apache.kafka.common.protocol.types.Schema$Visitor.class org.apache.kafka.common.protocol.types.Field$Int64.class org.apache.kafka.common.protocol.types.Type$3.class org.apache.kafka.common.protocol.types.Field$Int8.class org.apache.kafka.common.protocol.types.Type$8.class org.apache.kafka.common.protocol.types.Type$11.class org.apache.kafka.common.protocol.types.Field.class org.apache.kafka.common.protocol.types.Type.class org.apache.kafka.common.protocol.types.Type$2.class org.apache.kafka.common.protocol.types.Field$Int32.class org.apache.kafka.common.protocol.types.ArrayOf.class org.apache.kafka.common.protocol.types.Type$4.class org.apache.kafka.common.protocol.types.Field$Str.class org.apache.kafka.common.protocol.types.Type$5.class org.apache.kafka.common.protocol.types.Type$10.class org.apache.kafka.common.protocol.types.Type$12.class org.apache.kafka.common.protocol.types.Field$Int16.class org.apache.kafka.common.protocol.types.Type$1.class org.apache.kafka.common.protocol.types.BoundField.class org.apache.kafka.common.protocol.types.Field$NullableStr.class org.apache.kafka.common.protocol.types.Type$9.class org.apache.kafka.common.protocol.types.Struct.class org.apache.kafka.common.protocol.types.Type$13.class org.apache.kafka.common.protocol.types.Type$7.class org.apache.kafka.common.protocol.types.Schema.class org.apache.kafka.common.protocol.types.SchemaException.class org.apache.kafka.common.protocol.Errors$31.class org.apache.kafka.common.protocol.Errors$39.class org.apache.kafka.common.protocol.Errors$25.class org.apache.kafka.common.protocol.Errors$68.class org.apache.kafka.common.protocol.Errors$42.class org.apache.kafka.common.protocol.Errors$73.class org.apache.kafka.common.protocol.Errors$59.class org.apache.kafka.common.protocol.Errors$36.class org.apache.kafka.common.protocol.Errors$16.class org.apache.kafka.common.protocol.Errors$11.class org.apache.kafka.common.protocol.Errors$46.class org.apache.kafka.common.protocol.Errors$18.class org.apache.kafka.common.protocol.Errors$17.class org.apache.kafka.common.protocol.Errors$29.class org.apache.kafka.common.protocol.Errors$66.class org.apache.kafka.common.protocol.Errors$56.class org.apache.kafka.common.protocol.Errors$43.class org.apache.kafka.common.protocol.Errors$10.class org.apache.kafka.common.protocol.Errors$49.class org.apache.kafka.common.protocol.Errors$27.class org.apache.kafka.common.protocol.Errors$2.class org.apache.kafka.common.protocol.Errors$14.class org.apache.kafka.common.protocol.Errors$4.class org.apache.kafka.common.protocol.CommonFields.class org.apache.kafka.common.protocol.Errors$54.class org.apache.kafka.common.protocol.Errors$5.class org.apache.kafka.common.protocol.ApiKeys.class org.apache.kafka.common.protocol.Errors$53.class org.apache.kafka.common.protocol.Errors$58.class org.apache.kafka.common.protocol.Errors$47.class org.apache.kafka.common.protocol.Errors$41.class org.apache.kafka.common.protocol.Errors$37.class org.apache.kafka.common.protocol.Errors$65.class org.apache.kafka.common.protocol.Errors$15.class org.apache.kafka.common.protocol.Errors$19.class org.apache.kafka.common.protocol.Errors$8.class org.apache.kafka.common.protocol.Errors$60.class org.apache.kafka.common.protocol.Errors.class org.apache.kafka.common.protocol.Errors$34.class org.apache.kafka.common.protocol.Errors$69.class org.apache.kafka.common.protocol.Errors$32.class org.apache.kafka.common.protocol.Errors$61.class org.apache.kafka.common.protocol.Errors$64.class org.apache.kafka.common.protocol.Errors$9.class org.apache.kafka.common.protocol.Errors$57.class org.apache.kafka.common.protocol.Errors$48.class org.apache.kafka.common.protocol.Errors$40.class org.apache.kafka.common.protocol.Errors$50.class org.apache.kafka.common.protocol.Errors$72.class org.apache.kafka.common.protocol.Errors$6.class org.apache.kafka.common.protocol.Errors$24.class org.apache.kafka.common.protocol.Errors$38.class org.apache.kafka.common.protocol.Errors$33.class org.apache.kafka.common.protocol.Errors$55.class org.apache.kafka.common.protocol.Errors$7.class org.apache.kafka.common.protocol.Errors$44.class org.apache.kafka.common.protocol.Errors$67.class org.apache.kafka.common.protocol.Errors$26.class org.apache.kafka.common.protocol.Errors$35.class org.apache.kafka.common.protocol.Errors$22.class org.apache.kafka.common.protocol.Errors$30.class org.apache.kafka.common.protocol.Errors$62.class org.apache.kafka.common.protocol.Errors$3.class org.apache.kafka.common.protocol.Errors$20.class org.apache.kafka.common.protocol.Errors$28.class org.apache.kafka.common.protocol.Errors$71.class org.apache.kafka.common.protocol.Errors$51.class org.apache.kafka.common.protocol.Errors$ApiExceptionBuilder.class org.apache.kafka.common.protocol.Errors$52.class org.apache.kafka.common.protocol.Errors$63.class org.apache.kafka.common.protocol.Errors$12.class org.apache.kafka.common.protocol.Errors$45.class org.apache.kafka.common.protocol.ApiKeys$2.class org.apache.kafka.common.Reconfigurable.class org.apache.kafka.common.KafkaFuture.class org.apache.kafka.common.record.FileLogInputStream$FileChannelRecordBatch.class org.apache.kafka.common.record.FileRecords.class org.apache.kafka.common.record.CompressionType$4.class org.apache.kafka.common.record.MutableRecordBatch.class org.apache.kafka.common.record.EndTransactionMarker.class org.apache.kafka.common.record.LogInputStream.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$LegacyFileChannelRecordBatch.class org.apache.kafka.common.record.MemoryRecords$RecordFilter$BatchRetention.class org.apache.kafka.common.record.CompressionType$2.class org.apache.kafka.common.record.KafkaLZ4BlockOutputStream$BD.class org.apache.kafka.common.record.RecordBatch.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$1.class org.apache.kafka.common.record.CompressionRatioEstimator.class org.apache.kafka.common.record.MemoryRecords$FilterResult.class org.apache.kafka.common.record.MemoryRecords.class org.apache.kafka.common.record.BufferSupplier$1.class org.apache.kafka.common.record.KafkaLZ4BlockOutputStream$FLG.class org.apache.kafka.common.record.DefaultRecordBatch$1.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$DeepRecordsIterator.class org.apache.kafka.common.record.KafkaLZ4BlockInputStream.class org.apache.kafka.common.record.TimestampType.class org.apache.kafka.common.record.CompressionType.class org.apache.kafka.common.record.CompressionType$1.class org.apache.kafka.common.record.MemoryRecordsBuilder.class org.apache.kafka.common.record.KafkaLZ4BlockOutputStream.class org.apache.kafka.common.record.FileRecords$LogOffsetPosition.class org.apache.kafka.common.record.CompressionType$SnappyConstructors.class org.apache.kafka.common.record.DefaultRecordBatch$DefaultFileChannelRecordBatch.class org.apache.kafka.common.record.MemoryRecordsBuilder$RecordsInfo.class org.apache.kafka.common.record.FileRecords$TimestampAndOffset.class org.apache.kafka.common.record.AbstractRecordBatch.class org.apache.kafka.common.record.RecordFormat.class org.apache.kafka.common.record.ConvertedRecords.class org.apache.kafka.common.record.Records.class org.apache.kafka.common.record.ControlRecordType.class org.apache.kafka.common.record.BufferSupplier$DefaultSupplier.class org.apache.kafka.common.record.AbstractRecords.class org.apache.kafka.common.record.AbstractRecords$1.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$DataLogInputStream.class org.apache.kafka.common.record.MemoryRecords$RecordFilter.class org.apache.kafka.common.record.LegacyRecord.class org.apache.kafka.common.record.AbstractRecords$2.class org.apache.kafka.common.record.RecordsProcessingStats.class org.apache.kafka.common.record.MemoryRecords$1.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$BasicLegacyRecordBatch.class org.apache.kafka.common.record.FileRecords$1.class org.apache.kafka.common.record.Record.class org.apache.kafka.common.record.DefaultRecordBatch$2.class org.apache.kafka.common.record.DefaultRecord.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$ByteBufferLegacyRecordBatch.class org.apache.kafka.common.record.BufferSupplier.class org.apache.kafka.common.record.DefaultRecordBatch.class org.apache.kafka.common.record.FileLogInputStream.class org.apache.kafka.common.record.AbstractLegacyRecordBatch.class org.apache.kafka.common.record.SimpleRecord.class org.apache.kafka.common.record.CompressionType$3.class org.apache.kafka.common.record.RecordBatchIterator.class org.apache.kafka.common.record.ByteBufferLogInputStream.class org.apache.kafka.common.record.MemoryRecordsBuilder$1.class org.apache.kafka.common.record.DefaultRecordBatch$RecordIterator.class org.apache.kafka.common.record.AbstractRecords$RecordBatchAndRecords.class org.apache.kafka.common.record.InvalidRecordException.class org.apache.kafka.common.Node.class org.apache.kafka.common.KafkaFuture$Function.class org.apache.kafka.common.errors.InvalidRequiredAcksException.class org.apache.kafka.common.errors.InvalidGroupIdException.class org.apache.kafka.common.errors.TopicExistsException.class org.apache.kafka.common.errors.ReassignmentInProgressException.class org.apache.kafka.common.errors.OffsetOutOfRangeException.class org.apache.kafka.common.errors.InvalidConfigurationException.class org.apache.kafka.common.errors.ProducerFencedException.class org.apache.kafka.common.errors.ConcurrentTransactionsException.class org.apache.kafka.common.errors.NotLeaderForPartitionException.class org.apache.kafka.common.errors.NotEnoughReplicasException.class org.apache.kafka.common.errors.InvalidTopicException.class org.apache.kafka.common.errors.NetworkException.class org.apache.kafka.common.errors.KafkaStorageException.class org.apache.kafka.common.errors.TransactionCoordinatorFencedException.class org.apache.kafka.common.errors.OutOfOrderSequenceException.class org.apache.kafka.common.errors.InterruptException.class org.apache.kafka.common.errors.InvalidReplicaAssignmentException.class org.apache.kafka.common.errors.NotCoordinatorForGroupException.class org.apache.kafka.common.errors.RebalanceInProgressException.class org.apache.kafka.common.errors.LeaderNotAvailableException.class org.apache.kafka.common.errors.SerializationException.class org.apache.kafka.common.errors.CoordinatorLoadInProgressException.class org.apache.kafka.common.errors.UnsupportedForMessageFormatException.class org.apache.kafka.common.errors.LogDirNotFoundException.class org.apache.kafka.common.errors.RetriableException.class org.apache.kafka.common.errors.ControllerMovedException.class org.apache.kafka.common.errors.InvalidPidMappingException.class org.apache.kafka.common.errors.DuplicateSequenceException.class org.apache.kafka.common.errors.TopicAuthorizationException.class org.apache.kafka.common.errors.InvalidRequestException.class org.apache.kafka.common.errors.AuthorizationException.class org.apache.kafka.common.errors.DelegationTokenDisabledException.class org.apache.kafka.common.errors.DelegationTokenExpiredException.class org.apache.kafka.common.errors.UnknownServerException.class org.apache.kafka.common.errors.CorruptRecordException.class org.apache.kafka.common.errors.NotCoordinatorException.class org.apache.kafka.common.errors.InconsistentGroupProtocolException.class org.apache.kafka.common.errors.InvalidTxnStateException.class org.apache.kafka.common.errors.PolicyViolationException.class org.apache.kafka.common.errors.UnknownProducerIdException.class org.apache.kafka.common.errors.AuthenticationException.class org.apache.kafka.common.errors.DelegationTokenNotFoundException.class org.apache.kafka.common.errors.InvalidFetchSizeException.class org.apache.kafka.common.errors.InvalidCommitOffsetSizeException.class org.apache.kafka.common.errors.OffsetMetadataTooLarge.class org.apache.kafka.common.errors.IllegalGenerationException.class org.apache.kafka.common.errors.TransactionalIdAuthorizationException.class org.apache.kafka.common.errors.UnknownTopicOrPartitionException.class org.apache.kafka.common.errors.DisconnectException.class org.apache.kafka.common.errors.DelegationTokenOwnerMismatchException.class org.apache.kafka.common.errors.InvalidTimestampException.class org.apache.kafka.common.errors.FetchSessionIdNotFoundException.class org.apache.kafka.common.errors.IllegalSaslStateException.class org.apache.kafka.common.errors.SaslAuthenticationException.class org.apache.kafka.common.errors.ApiException.class org.apache.kafka.common.errors.InvalidReplicationFactorException.class org.apache.kafka.common.errors.GroupLoadInProgressException.class org.apache.kafka.common.errors.UnsupportedVersionException.class org.apache.kafka.common.errors.InvalidPartitionsException.class org.apache.kafka.common.errors.GroupNotEmptyException.class org.apache.kafka.common.errors.InvalidMetadataException.class org.apache.kafka.common.errors.ClusterAuthorizationException.class org.apache.kafka.common.errors.UnsupportedByAuthenticationException.class org.apache.kafka.common.errors.SslAuthenticationException.class org.apache.kafka.common.errors.ReplicaNotAvailableException.class org.apache.kafka.common.errors.SecurityDisabledException.class org.apache.kafka.common.errors.InvalidSessionTimeoutException.class org.apache.kafka.common.errors.InvalidFetchSessionEpochException.class org.apache.kafka.common.errors.BrokerNotAvailableException.class org.apache.kafka.common.errors.InvalidPrincipalTypeException.class org.apache.kafka.common.errors.InvalidTxnTimeoutException.class org.apache.kafka.common.errors.TimeoutException.class org.apache.kafka.common.errors.WakeupException.class org.apache.kafka.common.errors.DelegationTokenAuthorizationException.class org.apache.kafka.common.errors.UnsupportedSaslMechanismException.class org.apache.kafka.common.errors.GroupAuthorizationException.class org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException.class org.apache.kafka.common.errors.GroupIdNotFoundException.class org.apache.kafka.common.errors.RecordBatchTooLargeException.class org.apache.kafka.common.errors.UnknownMemberIdException.class org.apache.kafka.common.errors.CoordinatorNotAvailableException.class org.apache.kafka.common.errors.OperationNotAttemptedException.class org.apache.kafka.common.errors.InvalidOffsetException.class org.apache.kafka.common.errors.NotControllerException.class org.apache.kafka.common.errors.RecordTooLargeException.class org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException.class org.apache.kafka.common.KafkaException.class org.apache.kafka.common.KafkaFuture$BiConsumer.class org.apache.kafka.common.security.JaasContext.class org.apache.kafka.common.security.kerberos.KerberosShortNamer.class org.apache.kafka.common.security.kerberos.KerberosLogin.class org.apache.kafka.common.security.kerberos.KerberosRule.class org.apache.kafka.common.security.kerberos.KerberosName.class org.apache.kafka.common.security.kerberos.BadFormatString.class org.apache.kafka.common.security.kerberos.KerberosLogin$1.class org.apache.kafka.common.security.kerberos.NoMatchingRule.class org.apache.kafka.common.security.JaasConfig.class org.apache.kafka.common.security.authenticator.SaslClientCallbackHandler.class org.apache.kafka.common.security.authenticator.AuthCallbackHandler.class org.apache.kafka.common.security.authenticator.SaslClientAuthenticator$1.class org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.class org.apache.kafka.common.security.authenticator.AbstractLogin.class org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler.class org.apache.kafka.common.security.authenticator.SaslClientAuthenticator$SaslState.class org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$3.class org.apache.kafka.common.security.authenticator.AbstractLogin$LoginCallbackHandler.class org.apache.kafka.common.security.authenticator.CredentialCache$Cache.class org.apache.kafka.common.security.authenticator.DefaultLogin.class org.apache.kafka.common.security.authenticator.CredentialCache.class org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$1.class org.apache.kafka.common.security.authenticator.LoginManager.class org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$SaslState.class org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.class org.apache.kafka.common.security.authenticator.SaslClientAuthenticator$3.class org.apache.kafka.common.security.authenticator.SaslClientAuthenticator$2.class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder.class org.apache.kafka.common.security.authenticator.Login.class org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$2.class org.apache.kafka.common.security.plain.PlainSaslServer.class org.apache.kafka.common.security.plain.PlainSaslServer$PlainSaslServerFactory.class org.apache.kafka.common.security.plain.PlainSaslServerProvider.class org.apache.kafka.common.security.plain.PlainLoginModule.class org.apache.kafka.common.security.token.delegation.DelegationTokenCredentialCallback.class org.apache.kafka.common.security.token.delegation.DelegationToken.class org.apache.kafka.common.security.token.delegation.TokenInformation.class org.apache.kafka.common.security.token.delegation.DelegationTokenCache.class org.apache.kafka.common.security.JaasContext$Type.class org.apache.kafka.common.security.scram.ScramExtensions.class org.apache.kafka.common.security.scram.ScramMechanism.class org.apache.kafka.common.security.scram.ScramLoginModule.class org.apache.kafka.common.security.scram.ScramExtensionsCallback.class org.apache.kafka.common.security.scram.ScramCredential.class org.apache.kafka.common.security.scram.ScramSaslServerProvider.class org.apache.kafka.common.security.scram.ScramSaslServer$ScramSaslServerFactory.class org.apache.kafka.common.security.scram.ScramCredentialUtils.class org.apache.kafka.common.security.scram.ScramSaslClient$1.class org.apache.kafka.common.security.scram.ScramSaslServer.class org.apache.kafka.common.security.scram.ScramSaslClient$ScramSaslClientFactory.class org.apache.kafka.common.security.scram.ScramMessages$ServerFirstMessage.class org.apache.kafka.common.security.scram.ScramSaslClient.class org.apache.kafka.common.security.scram.ScramFormatter.class org.apache.kafka.common.security.scram.ScramSaslClient$State.class org.apache.kafka.common.security.scram.ScramSaslClientProvider.class org.apache.kafka.common.security.scram.ScramMessages$AbstractScramMessage.class org.apache.kafka.common.security.scram.ScramMessages$ServerFinalMessage.class org.apache.kafka.common.security.scram.ScramMessages$ClientFirstMessage.class org.apache.kafka.common.security.scram.ScramSaslServer$1.class org.apache.kafka.common.security.scram.ScramMessages$ClientFinalMessage.class org.apache.kafka.common.security.scram.ScramMessages.class org.apache.kafka.common.security.scram.ScramSaslServer$State.class org.apache.kafka.common.security.scram.ScramCredentialCallback.class org.apache.kafka.common.security.scram.ScramServerCallbackHandler.class org.apache.kafka.common.security.auth.KafkaPrincipalBuilder.class org.apache.kafka.common.security.auth.SslAuthenticationContext.class org.apache.kafka.common.security.auth.SaslAuthenticationContext.class org.apache.kafka.common.security.auth.DefaultPrincipalBuilder.class org.apache.kafka.common.security.auth.SecurityProtocol.class org.apache.kafka.common.security.auth.PrincipalBuilder.class org.apache.kafka.common.security.auth.KafkaPrincipal.class org.apache.kafka.common.security.auth.PlaintextAuthenticationContext.class org.apache.kafka.common.security.auth.AuthenticationContext.class org.apache.kafka.common.security.JaasUtils.class org.apache.kafka.common.security.ssl.SslFactory$CertificateEntries.class org.apache.kafka.common.security.ssl.SslFactory$1.class org.apache.kafka.common.security.ssl.SslFactory$SecurityStore.class org.apache.kafka.common.security.ssl.SslFactory$SSLConfigValidatorEngine.class org.apache.kafka.common.security.ssl.SslFactory.class org.apache.kafka.common.header.Headers.class org.apache.kafka.common.header.internals.RecordHeaders$2.class org.apache.kafka.common.header.internals.RecordHeaders.class org.apache.kafka.common.header.internals.RecordHeader.class org.apache.kafka.common.header.internals.RecordHeaders$FilterByKeyIterator.class org.apache.kafka.common.header.internals.RecordHeaders$1.class org.apache.kafka.common.header.Header.class org.apache.kafka.common.internals.PartitionStates$PartitionState.class org.apache.kafka.common.internals.FatalExitError.class org.apache.kafka.common.internals.PartitionStates.class org.apache.kafka.common.internals.KafkaFutureImpl$1.class org.apache.kafka.common.internals.Topic.class org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.class org.apache.kafka.common.internals.ClusterResourceListeners.class org.apache.kafka.common.internals.KafkaFutureImpl$Applicant.class org.apache.kafka.common.internals.KafkaFutureImpl$WhenCompleteBiConsumer.class org.apache.kafka.common.internals.KafkaFutureImpl.class org.apache.kafka.common.Configurable.class org.apache.kafka.common.PartitionInfo.class org.apache.kafka.common.TopicPartitionReplica.class org.apache.kafka.common.acl.AclBinding.class org.apache.kafka.common.acl.AccessControlEntry.class org.apache.kafka.common.acl.AclPermissionType.class org.apache.kafka.common.acl.AclOperation.class org.apache.kafka.common.acl.AccessControlEntryData.class org.apache.kafka.common.acl.AclBindingFilter.class org.apache.kafka.common.acl.AccessControlEntryFilter.class org.apache.kafka.common.ClusterResource.class org.apache.kafka.common.serialization.Serdes$WrapperSerde.class org.apache.kafka.common.serialization.Serdes.class org.apache.kafka.common.serialization.Serdes$StringSerde.class org.apache.kafka.common.serialization.BytesSerializer.class org.apache.kafka.common.serialization.ByteBufferDeserializer.class org.apache.kafka.common.serialization.DoubleDeserializer.class org.apache.kafka.common.serialization.ByteArrayDeserializer.class org.apache.kafka.common.serialization.Serdes$ShortSerde.class org.apache.kafka.common.serialization.LongDeserializer.class org.apache.kafka.common.serialization.Deserializer.class org.apache.kafka.common.serialization.Serializer.class org.apache.kafka.common.serialization.FloatSerializer.class org.apache.kafka.common.serialization.Serde.class org.apache.kafka.common.serialization.LongSerializer.class org.apache.kafka.common.serialization.StringDeserializer.class org.apache.kafka.common.serialization.ExtendedDeserializer.class org.apache.kafka.common.serialization.ExtendedSerializer$Wrapper.class org.apache.kafka.common.serialization.Serdes$ByteArraySerde.class org.apache.kafka.common.serialization.BytesDeserializer.class org.apache.kafka.common.serialization.Serdes$BytesSerde.class org.apache.kafka.common.serialization.DoubleSerializer.class org.apache.kafka.common.serialization.Serdes$FloatSerde.class org.apache.kafka.common.serialization.ShortSerializer.class org.apache.kafka.common.serialization.Serdes$LongSerde.class org.apache.kafka.common.serialization.ExtendedDeserializer$Wrapper.class org.apache.kafka.common.serialization.ByteArraySerializer.class org.apache.kafka.common.serialization.ByteBufferSerializer.class org.apache.kafka.common.serialization.StringSerializer.class org.apache.kafka.common.serialization.Serdes$ByteBufferSerde.class org.apache.kafka.common.serialization.Serdes$DoubleSerde.class org.apache.kafka.common.serialization.Serdes$IntegerSerde.class org.apache.kafka.common.serialization.IntegerSerializer.class org.apache.kafka.common.serialization.ExtendedSerializer.class org.apache.kafka.common.serialization.ShortDeserializer.class org.apache.kafka.common.serialization.FloatDeserializer.class org.apache.kafka.common.serialization.IntegerDeserializer.class org.apache.kafka.common.cache.Cache.class org.apache.kafka.common.cache.LRUCache$1.class org.apache.kafka.common.cache.LRUCache.class org.apache.kafka.common.cache.SynchronizedCache.class org.apache.kafka.common.MetricName.class org.apache.kafka.common.metrics.MetricsReporter.class org.apache.kafka.common.metrics.Metrics$ExpireSensorTask.class org.apache.kafka.common.metrics.Gauge.class org.apache.kafka.common.metrics.KafkaMetric.class org.apache.kafka.common.metrics.CompoundStat.class org.apache.kafka.common.metrics.Quota.class org.apache.kafka.common.metrics.Metrics.class org.apache.kafka.common.metrics.Measurable.class org.apache.kafka.common.metrics.CompoundStat$NamedMeasurable.class org.apache.kafka.common.metrics.JmxReporter$KafkaMbean.class org.apache.kafka.common.metrics.stats.SampledStat.class org.apache.kafka.common.metrics.stats.Frequencies$HistogramSample.class org.apache.kafka.common.metrics.stats.Percentiles.class org.apache.kafka.common.metrics.stats.Percentiles$1.class org.apache.kafka.common.metrics.stats.Histogram$LinearBinScheme.class org.apache.kafka.common.metrics.stats.SampledStat$Sample.class org.apache.kafka.common.metrics.stats.Percentiles$BucketSizing.class org.apache.kafka.common.metrics.stats.Rate$1.class org.apache.kafka.common.metrics.stats.Sum.class org.apache.kafka.common.metrics.stats.Avg.class org.apache.kafka.common.metrics.stats.Rate.class org.apache.kafka.common.metrics.stats.Min.class org.apache.kafka.common.metrics.stats.Max.class org.apache.kafka.common.metrics.stats.Percentile.class org.apache.kafka.common.metrics.stats.Meter.class org.apache.kafka.common.metrics.stats.Frequencies.class org.apache.kafka.common.metrics.stats.Histogram.class org.apache.kafka.common.metrics.stats.Frequencies$1.class org.apache.kafka.common.metrics.stats.Percentiles$HistogramSample.class org.apache.kafka.common.metrics.stats.Histogram$ConstantBinScheme.class org.apache.kafka.common.metrics.stats.Rate$SampledTotal.class org.apache.kafka.common.metrics.stats.SimpleRate.class org.apache.kafka.common.metrics.stats.Value.class org.apache.kafka.common.metrics.stats.Total.class org.apache.kafka.common.metrics.stats.Frequency.class org.apache.kafka.common.metrics.stats.Count.class org.apache.kafka.common.metrics.stats.Histogram$BinScheme.class org.apache.kafka.common.metrics.MetricValueProvider.class org.apache.kafka.common.metrics.JmxReporter.class org.apache.kafka.common.metrics.Stat.class org.apache.kafka.common.metrics.Metrics$1.class org.apache.kafka.common.metrics.MeasurableStat.class org.apache.kafka.common.metrics.MetricConfig.class org.apache.kafka.common.metrics.QuotaViolationException.class org.apache.kafka.common.metrics.Sensor$RecordingLevel.class org.apache.kafka.common.metrics.Metrics$2.class org.apache.kafka.common.metrics.Sensor.class org.apache.kafka.common.config.ConfigDef$NonEmptyString.class org.apache.kafka.common.config.types.Password.class org.apache.kafka.common.config.ConfigDef.class org.apache.kafka.common.config.ConfigDef$2.class org.apache.kafka.common.config.ConfigValue.class org.apache.kafka.common.config.ConfigDef$Range.class org.apache.kafka.common.config.ConfigDef$3.class org.apache.kafka.common.config.internals.BrokerSecurityConfigs.class org.apache.kafka.common.config.ConfigDef$ValidString.class org.apache.kafka.common.config.ConfigException.class org.apache.kafka.common.config.ConfigDef$4.class org.apache.kafka.common.config.ConfigResource.class org.apache.kafka.common.config.ConfigDef$NonEmptyStringWithoutControlChars.class org.apache.kafka.common.config.ConfigDef$Importance.class org.apache.kafka.common.config.ConfigDef$Validator.class org.apache.kafka.common.config.SaslConfigs.class org.apache.kafka.common.config.ConfigDef$1.class org.apache.kafka.common.config.SslConfigs.class org.apache.kafka.common.config.AbstractConfig.class org.apache.kafka.common.config.ConfigDef$Recommender.class org.apache.kafka.common.config.ConfigDef$CompositeValidator.class org.apache.kafka.common.config.ConfigResource$Type.class org.apache.kafka.common.config.Config.class org.apache.kafka.common.config.ConfigDef$ValidList.class org.apache.kafka.common.config.ConfigDef$Width.class org.apache.kafka.common.config.TopicConfig.class org.apache.kafka.common.config.ConfigDef$ConfigKey.class org.apache.kafka.common.config.ConfigDef$Type.class org.apache.kafka.common.config.AbstractConfig$RecordingMap.class org.apache.kafka.common.config.ConfigDef$NonNullValidator.class org.apache.kafka.common.resource.ResourceType.class org.apache.kafka.common.resource.ResourceFilter.class org.apache.kafka.common.resource.Resource.class org.apache.kafka.common.TopicPartition.class org.apache.kafka.common.KafkaFuture$BaseFunction.class org.apache.kafka.common.annotation.InterfaceStability$Stable.class org.apache.kafka.common.annotation.InterfaceStability$Unstable.class org.apache.kafka.common.annotation.InterfaceStability.class org.apache.kafka.common.annotation.InterfaceStability$Evolving.class org.apache.kafka.common.Cluster.class org.apache.kafka.common.utils.Bytes$LexicographicByteArrayComparator.class org.apache.kafka.common.utils.CloseableIterator.class org.apache.kafka.common.utils.Base64$Factory.class org.apache.kafka.common.utils.Exit.class org.apache.kafka.common.utils.AbstractIterator.class org.apache.kafka.common.utils.AbstractIterator$State.class org.apache.kafka.common.utils.KafkaThread.class org.apache.kafka.common.utils.Shell.class org.apache.kafka.common.utils.Exit$2.class org.apache.kafka.common.utils.Sanitizer.class org.apache.kafka.common.utils.Bytes$1.class org.apache.kafka.common.utils.ImplicitLinkedHashSet$ImplicitLinkedHashSetIterator.class org.apache.kafka.common.utils.Bytes.class org.apache.kafka.common.utils.LoggingSignalHandler$1.class org.apache.kafka.common.utils.SecurityUtils.class org.apache.kafka.common.utils.Shell$ShellTimeoutTimerTask.class org.apache.kafka.common.utils.MappedByteBuffers.class org.apache.kafka.common.utils.CopyOnWriteMap.class org.apache.kafka.common.utils.Base64$Java7Factory.class org.apache.kafka.common.utils.Base64$Encoder.class org.apache.kafka.common.utils.PureJavaCrc32C.class org.apache.kafka.common.utils.ImplicitLinkedHashSet$Element.class org.apache.kafka.common.utils.ByteBufferInputStream.class org.apache.kafka.common.utils.Crc32C.class org.apache.kafka.common.utils.Base64$Java8Factory$3.class org.apache.kafka.common.utils.Base64$Java8Factory.class org.apache.kafka.common.utils.LogContext$AbstractKafkaLogger.class org.apache.kafka.common.utils.Base64.class org.apache.kafka.common.utils.SystemScheduler.class org.apache.kafka.common.utils.Base64$Decoder.class org.apache.kafka.common.utils.SystemTime.class org.apache.kafka.common.utils.Java$1.class org.apache.kafka.common.utils.Scheduler.class org.apache.kafka.common.utils.Utils$1.class org.apache.kafka.common.utils.Crc32C$PureJavaChecksumFactory.class org.apache.kafka.common.utils.Utils.class org.apache.kafka.common.utils.AppInfoParser$ImmutableValue.class org.apache.kafka.common.utils.LogContext$LocationAwareKafkaLogger.class org.apache.kafka.common.utils.ImplicitLinkedHashSet$HeadElement.class org.apache.kafka.common.utils.Shell$ExitCodeException.class org.apache.kafka.common.utils.Exit$Procedure.class org.apache.kafka.common.utils.ImplicitLinkedHashSet.class org.apache.kafka.common.utils.CollectionUtils.class org.apache.kafka.common.utils.Crc32C$ChecksumFactory.class org.apache.kafka.common.utils.Base64$Java8Factory$2.class org.apache.kafka.common.utils.Shell$1.class org.apache.kafka.common.utils.Shell$ShellCommandExecutor.class org.apache.kafka.common.utils.LogContext$LocationIgnorantKafkaLogger.class org.apache.kafka.common.utils.LoggingSignalHandler.class org.apache.kafka.common.utils.AppInfoParser.class org.apache.kafka.common.utils.Crc32C$Java9ChecksumFactory.class org.apache.kafka.common.utils.Java$Version.class org.apache.kafka.common.utils.AbstractIterator$1.class org.apache.kafka.common.utils.Bytes$ByteArrayComparator.class org.apache.kafka.common.utils.Checksums.class org.apache.kafka.common.utils.ByteUtils.class org.apache.kafka.common.utils.Crc32.class org.apache.kafka.common.utils.Base64$Java8Factory$1.class org.apache.kafka.common.utils.Java.class org.apache.kafka.common.utils.Base64$Java7Factory$1.class org.apache.kafka.common.utils.KafkaThread$1.class org.apache.kafka.common.utils.AppInfoParser$AppInfo.class org.apache.kafka.common.utils.LogContext.class org.apache.kafka.common.utils.AppInfoParser$AppInfoMBean.class org.apache.kafka.common.utils.Crc32C$1.class org.apache.kafka.common.utils.Base64$Java8Factory$4.class org.apache.kafka.common.utils.ImplicitLinkedHashSet$1.class org.apache.kafka.common.utils.Base64$1.class org.apache.kafka.common.utils.Base64$Java7Factory$3.class org.apache.kafka.common.utils.Time.class org.apache.kafka.common.utils.Base64$Java7Factory$2.class org.apache.kafka.common.utils.Base64$Java7Factory$4.class org.apache.kafka.common.utils.OperatingSystem.class org.apache.kafka.common.utils.ByteBufferOutputStream.class org.apache.kafka.common.utils.CircularIterator.class org.apache.kafka.common.utils.Exit$1.class org.apache.kafka.common.network.Selector$SelectorMetrics$1.class org.apache.kafka.common.network.SslTransportLayer$1.class org.apache.kafka.common.network.Selectable.class org.apache.kafka.common.network.TransportLayers.class org.apache.kafka.common.network.Selector$CloseMode.class org.apache.kafka.common.network.Send.class org.apache.kafka.common.network.SslChannelBuilder.class org.apache.kafka.common.network.SaslChannelBuilder.class org.apache.kafka.common.network.ChannelBuilders.class org.apache.kafka.common.network.Selector.class org.apache.kafka.common.network.ListenerName.class org.apache.kafka.common.network.PlaintextTransportLayer.class org.apache.kafka.common.network.SslTransportLayer.class org.apache.kafka.common.network.SslChannelBuilder$1.class org.apache.kafka.common.network.MultiSend.class org.apache.kafka.common.network.ByteBufferSend.class org.apache.kafka.common.network.NetworkReceive.class org.apache.kafka.common.network.Authenticator.class org.apache.kafka.common.network.ChannelState.class org.apache.kafka.common.network.Selector$SelectorMetrics.class org.apache.kafka.common.network.ListenerReconfigurable.class org.apache.kafka.common.network.Receive.class org.apache.kafka.common.network.ChannelBuilder.class org.apache.kafka.common.network.KafkaChannel.class org.apache.kafka.common.network.PlaintextChannelBuilder.class org.apache.kafka.common.network.TransportLayer.class org.apache.kafka.common.network.Mode.class org.apache.kafka.common.network.NetworkSend.class org.apache.kafka.common.network.ChannelBuilders$1.class org.apache.kafka.common.network.PlaintextChannelBuilder$PlaintextAuthenticator.class org.apache.kafka.common.network.PlaintextChannelBuilder$1.class org.apache.kafka.common.network.InvalidReceiveException.class org.apache.kafka.common.network.SslTransportLayer$State.class org.apache.kafka.common.network.ChannelState$State.class org.apache.kafka.common.network.SslChannelBuilder$SslAuthenticator.class org.apache.kafka.common.network.Selector$IdleExpiryManager.class org.apache.kafka.common.Metric.class org.apache.kafka.common.KafkaFuture$AllOfAdapter.class org.apache.kafka.clients.ConnectionState.class org.apache.kafka.clients.consumer.ConsumerRecords$ConcatenatedIterable.class org.apache.kafka.clients.consumer.StickyAssignor$SubscriptionComparator.class org.apache.kafka.clients.consumer.StickyAssignor$PartitionComparator.class org.apache.kafka.clients.consumer.StickyAssignor$1.class org.apache.kafka.clients.consumer.OffsetOutOfRangeException.class org.apache.kafka.clients.consumer.Consumer.class org.apache.kafka.clients.consumer.OffsetResetStrategy.class org.apache.kafka.clients.consumer.StickyAssignor$PartitionMovements.class org.apache.kafka.clients.consumer.StickyAssignor.class org.apache.kafka.clients.consumer.KafkaConsumer.class org.apache.kafka.clients.consumer.internals.Fetcher$ListOffsetResult.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitCompletion.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$1.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatResponseHandler.class org.apache.kafka.clients.consumer.internals.ConsumerInterceptors.class org.apache.kafka.clients.consumer.internals.RequestFutureListener.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$UnjoinedGroupException.class org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor.class org.apache.kafka.clients.consumer.internals.SubscriptionState.class org.apache.kafka.clients.consumer.internals.ConsumerMetrics.class org.apache.kafka.clients.consumer.internals.Fetcher$CompletedFetch.class org.apache.kafka.clients.consumer.internals.PartitionAssignor$Assignment.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.class org.apache.kafka.clients.consumer.internals.Fetcher$PartitionRecords.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.class org.apache.kafka.clients.consumer.internals.PartitionAssignor$Subscription.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$3.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$GroupCoordinatorMetrics$1.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.class org.apache.kafka.clients.consumer.internals.NoAvailableBrokersException.class org.apache.kafka.clients.consumer.internals.Fetcher$OffsetData.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$1.class org.apache.kafka.clients.consumer.internals.SubscriptionState$TopicPartitionState.class org.apache.kafka.clients.consumer.internals.RequestFuture.class org.apache.kafka.clients.consumer.internals.Fetcher.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$DefaultOffsetCommitCallback.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$1.class org.apache.kafka.clients.consumer.internals.Fetcher$2.class org.apache.kafka.clients.consumer.internals.Fetcher$FetchManagerMetrics.class org.apache.kafka.clients.consumer.internals.RequestFuture$2.class org.apache.kafka.clients.consumer.internals.SubscriptionState$SubscriptionType.class org.apache.kafka.clients.consumer.internals.Fetcher$4.class org.apache.kafka.clients.consumer.internals.StaleMetadataException.class #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	lz4-java-1.4.1.jar /org.lz4/lz4-java/1.4.1 查看lz4-java所有版本文件 snappy-java-1.1.7.1.jar /org.xerial.snappy/snappy-java/1.1.7.1 查看snappy-java所有版本文件 slf4j-api-1.7.25.jar /org.slf4j/slf4j-api/1.7.25 查看slf4j-api所有版本文件 bcpkix-jdk15on-1.59.jar /org.bouncycastle/bcpkix-jdk15on/1.59 查看bcpkix-jdk15on所有版本文件 junit-4.12.jar /junit/junit/4.12 查看junit所有版本文件 easymock-3.6.jar /org.easymock/easymock/3.6 查看easymock所有版本文件 powermock-module-junit4-2.0.0-beta.5.jar /org.powermock/powermock-module-junit4/2.0.0-beta.5 查看powermock-module-junit4所有版本文件 powermock-api-easymock-2.0.0-beta.5.jar /org.powermock/powermock-api-easymock/2.0.0-beta.5 查看powermock-api-easymock所有版本文件 slf4j-log4j12-1.7.25.jar /org.slf4j/slf4j-log4j12/1.7.25 查看slf4j-log4j12所有版本文件