登录注册

Jar文件详情内容

kafka-clients-2.5.0.jar

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

组织ID:	org.apache.kafka
项目ID:	kafka-clients
版本:	2.5.0
最后修改时间:	2020-04-15 09:19:46
包类型:	jar
标题:	Apache Kafka
相关URL:	https://kafka.apache.org
大小:	3.20MB

Maven引入代码:	`<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.5.0</version> </dependency>`
Gradle引入代码:	`org.apache.kafka:kafka-clients:2.5.0`
下载Jar包:	kafka-clients-2.5.0.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>2.5.0</version> <name>Apache Kafka</name> <url>https://kafka.apache.org</url> <licenses> <license> <name>The Apache Software License, Version 2.0</name> <url>https://www.apache.org/licenses/LICENSE-2.0.txt</url> <distribution>repo</distribution> </license> </licenses> <dependencies> <dependency> <groupId>com.github.luben</groupId> <artifactId>zstd-jni</artifactId> <version>1.4.4-7</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.lz4</groupId> <artifactId>lz4-java</artifactId> <version>1.7.1</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.xerial.snappy</groupId> <artifactId>snappy-java</artifactId> <version>1.1.7.3</version> <scope>compile</scope> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.30</version> <scope>compile</scope> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>2.10.2</version> <scope>provided</scope> </dependency> <dependency> <groupId>com.fasterxml.jackson.datatype</groupId> <artifactId>jackson-datatype-jdk8</artifactId> <version>2.10.2</version> <scope>test</scope> </dependency> <dependency> <groupId>org.bouncycastle</groupId> <artifactId>bcpkix-jdk15on</artifactId> <version>1.64</version> <scope>test</scope> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.13</version> <scope>test</scope> </dependency> <dependency> <groupId>org.mockito</groupId> <artifactId>mockito-core</artifactId> <version>3.2.4</version> <scope>test</scope> </dependency> <dependency> <groupId>com.fasterxml.jackson.jaxrs</groupId> <artifactId>jackson-jaxrs-json-provider</artifactId> <version>2.10.2</version> <scope>test</scope> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.30</version> <scope>test</scope> </dependency> </dependencies> </project>
Jar包内容:	展开复制 META-INF/MANIFEST.MF org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.class org.apache.kafka.clients.Metadata.class org.apache.kafka.clients.FetchSessionHandler.class org.apache.kafka.clients.NetworkClient.class org.apache.kafka.clients.ApiVersions.class org.apache.kafka.clients.producer.ProducerConfig.class org.apache.kafka.clients.producer.MockProducer.class org.apache.kafka.clients.producer.MockProducer$Completion.class org.apache.kafka.clients.producer.ProducerInterceptor.class org.apache.kafka.clients.producer.Producer.class org.apache.kafka.clients.producer.Partitioner.class org.apache.kafka.clients.producer.RecordMetadata.class org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.class org.apache.kafka.clients.producer.internals.ProducerInterceptors.class org.apache.kafka.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper.class org.apache.kafka.clients.producer.internals.StickyPartitionCache.class org.apache.kafka.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler.class org.apache.kafka.clients.producer.internals.TransactionManager$TopicPartitionEntry.class org.apache.kafka.clients.producer.internals.TransactionManager$State.class org.apache.kafka.clients.producer.internals.ErrorLoggingCallback.class org.apache.kafka.clients.producer.internals.TransactionManager$TxnRequestHandler.class org.apache.kafka.clients.producer.internals.BufferPool.class org.apache.kafka.clients.producer.internals.Sender$1.class org.apache.kafka.clients.producer.internals.Sender.class org.apache.kafka.clients.producer.internals.TransactionManager$EndTxnHandler.class org.apache.kafka.clients.producer.internals.ProducerBatch$Thunk.class org.apache.kafka.clients.producer.internals.RecordAccumulator$3.class org.apache.kafka.clients.producer.internals.TransactionManager$FindCoordinatorHandler.class org.apache.kafka.clients.producer.internals.TransactionManager.class org.apache.kafka.clients.producer.internals.ProducerBatch.class org.apache.kafka.clients.producer.internals.RecordAccumulator$1.class org.apache.kafka.clients.producer.internals.Sender$SenderMetrics.class org.apache.kafka.clients.producer.internals.TransactionManager$Priority.class org.apache.kafka.clients.producer.internals.TransactionManager$1.class org.apache.kafka.clients.producer.internals.IncompleteBatches.class org.apache.kafka.clients.producer.internals.TransactionalRequestResult.class org.apache.kafka.clients.producer.internals.ProducerMetadata.class org.apache.kafka.clients.producer.internals.RecordAccumulator.class org.apache.kafka.clients.producer.internals.FutureRecordMetadata.class org.apache.kafka.clients.producer.internals.TransactionManager$InitProducerIdHandler.class org.apache.kafka.clients.producer.internals.RecordAccumulator$RecordAppendResult.class org.apache.kafka.clients.producer.internals.ProducerMetrics.class org.apache.kafka.clients.producer.internals.ProducerBatch$FinalState.class org.apache.kafka.clients.producer.internals.RecordAccumulator$2.class org.apache.kafka.clients.producer.internals.ProduceRequestResult.class org.apache.kafka.clients.producer.internals.DefaultPartitioner.class org.apache.kafka.clients.producer.internals.RecordAccumulator$ReadyCheckResult.class org.apache.kafka.clients.producer.internals.TransactionManager$TxnOffsetCommitHandler.class org.apache.kafka.clients.producer.internals.SenderMetricsRegistry.class org.apache.kafka.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler.class org.apache.kafka.clients.producer.KafkaProducer$1.class org.apache.kafka.clients.producer.KafkaProducer$ClusterAndWaitTime.class org.apache.kafka.clients.producer.KafkaProducer.class org.apache.kafka.clients.producer.ProducerRecord.class org.apache.kafka.clients.producer.RoundRobinPartitioner.class org.apache.kafka.clients.producer.UniformStickyPartitioner.class org.apache.kafka.clients.producer.Callback.class org.apache.kafka.clients.producer.BufferExhaustedException.class org.apache.kafka.clients.producer.KafkaProducer$InterceptorCallback.class org.apache.kafka.clients.ConnectionState.class org.apache.kafka.clients.NetworkClient$State.class org.apache.kafka.clients.ApiVersion.class org.apache.kafka.clients.FetchSessionHandler$FetchRequestData.class org.apache.kafka.clients.CommonClientConfigs.class org.apache.kafka.clients.ClientUtils.class org.apache.kafka.clients.FetchSessionHandler$Builder.class org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater$InProgressData.class org.apache.kafka.clients.RequestCompletionHandler.class org.apache.kafka.clients.admin.KafkaAdminClient$22.class org.apache.kafka.clients.admin.ListConsumerGroupOffsetsResult.class org.apache.kafka.clients.admin.DeleteTopicsOptions.class org.apache.kafka.clients.admin.DescribeConsumerGroupsOptions.class org.apache.kafka.clients.admin.DescribeLogDirsOptions.class org.apache.kafka.clients.admin.NewTopic.class org.apache.kafka.clients.admin.KafkaAdminClient$ControllerNodeProvider.class org.apache.kafka.clients.admin.DescribeLogDirsResult$1.class org.apache.kafka.clients.admin.KafkaAdminClient$1.class org.apache.kafka.clients.admin.CreateTopicsOptions.class org.apache.kafka.clients.admin.ElectLeadersResult.class org.apache.kafka.clients.admin.ConsumerGroupListing.class org.apache.kafka.clients.admin.KafkaAdminClient$3.class org.apache.kafka.clients.admin.RecordsToDelete.class org.apache.kafka.clients.admin.ExpireDelegationTokenOptions.class org.apache.kafka.clients.admin.KafkaAdminClient$20.class org.apache.kafka.clients.admin.KafkaAdminClient$17$1.class org.apache.kafka.clients.admin.KafkaAdminClient$NodeProvider.class org.apache.kafka.clients.admin.KafkaAdminClient$19.class org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsResult$2.class org.apache.kafka.clients.admin.ConfigEntry$ConfigSynonym.class org.apache.kafka.clients.admin.ListPartitionReassignmentsResult.class org.apache.kafka.clients.admin.KafkaAdminClient$24.class org.apache.kafka.clients.admin.MemberToRemove.class org.apache.kafka.clients.admin.ListConsumerGroupsOptions.class org.apache.kafka.clients.admin.ListOffsetsResult.class org.apache.kafka.clients.admin.RenewDelegationTokenOptions.class org.apache.kafka.clients.admin.KafkaAdminClient$7.class org.apache.kafka.clients.admin.ConfigEntry$ConfigSource.class org.apache.kafka.clients.admin.AlterConfigsResult.class org.apache.kafka.clients.admin.DeletedRecords.class org.apache.kafka.clients.admin.DeleteAclsResult$FilterResult.class org.apache.kafka.clients.admin.NewPartitionReassignment.class org.apache.kafka.clients.admin.DescribeClusterResult.class org.apache.kafka.clients.admin.KafkaAdminClient$5.class org.apache.kafka.clients.admin.CreateDelegationTokenResult.class org.apache.kafka.clients.admin.DescribeDelegationTokenOptions.class org.apache.kafka.clients.admin.DeleteConsumerGroupsResult.class org.apache.kafka.clients.admin.AdminClient.class org.apache.kafka.clients.admin.KafkaAdminClient$26.class org.apache.kafka.clients.admin.DeleteTopicsResult.class org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsOptions.class org.apache.kafka.clients.admin.KafkaAdminClient$ListConsumerGroupsResults.class org.apache.kafka.clients.admin.KafkaAdminClient$2.class org.apache.kafka.clients.admin.DeleteRecordsResult.class org.apache.kafka.clients.admin.AbstractOptions.class org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult$ReplicaLogDirInfo.class org.apache.kafka.clients.admin.KafkaAdminClient$21.class org.apache.kafka.clients.admin.DescribeDelegationTokenResult.class org.apache.kafka.clients.admin.ListOffsetsOptions.class org.apache.kafka.clients.admin.TopicListing.class org.apache.kafka.clients.admin.DeleteAclsOptions.class org.apache.kafka.clients.admin.ElectPreferredLeadersOptions.class org.apache.kafka.clients.admin.KafkaAdminClient$23.class org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.class org.apache.kafka.clients.admin.OffsetSpec$LatestSpec.class org.apache.kafka.clients.admin.KafkaAdminClient$MetadataUpdateNodeIdProvider.class org.apache.kafka.clients.admin.DeleteConsumerGroupsOptions.class org.apache.kafka.clients.admin.DescribeTopicsOptions.class org.apache.kafka.clients.admin.KafkaAdminClient$4.class org.apache.kafka.clients.admin.DescribeReplicaLogDirsOptions.class org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsResult.class org.apache.kafka.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider.class org.apache.kafka.clients.admin.DescribeLogDirsResult.class org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsResult.class org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsResult$1.class org.apache.kafka.clients.admin.KafkaAdminClient$27.class org.apache.kafka.clients.admin.KafkaAdminClient$25.class org.apache.kafka.clients.admin.Config.class org.apache.kafka.clients.admin.KafkaAdminClient$18.class org.apache.kafka.clients.admin.ElectLeadersResult$1.class org.apache.kafka.clients.admin.Admin.class org.apache.kafka.clients.admin.ListTopicsResult.class org.apache.kafka.clients.admin.AlterReplicaLogDirsResult.class org.apache.kafka.clients.admin.KafkaAdminClient$TimeoutProcessorFactory.class org.apache.kafka.clients.admin.KafkaAdminClient$6.class org.apache.kafka.clients.admin.ListPartitionReassignmentsOptions.class org.apache.kafka.clients.admin.KafkaAdminClient$30.class org.apache.kafka.clients.admin.KafkaAdminClient$14.class org.apache.kafka.clients.admin.DescribeConfigsOptions.class org.apache.kafka.clients.admin.KafkaAdminClient$ConstantNodeIdProvider.class org.apache.kafka.clients.admin.internals.MetadataOperationContext.class org.apache.kafka.clients.admin.internals.AdminMetadataManager$State.class org.apache.kafka.clients.admin.internals.AdminMetadataManager$1.class org.apache.kafka.clients.admin.internals.AdminMetadataManager$AdminMetadataUpdater.class org.apache.kafka.clients.admin.internals.ConsumerGroupOperationContext.class org.apache.kafka.clients.admin.internals.AdminMetadataManager.class org.apache.kafka.clients.admin.KafkaAdminClient$29.class org.apache.kafka.clients.admin.NewPartitions.class org.apache.kafka.clients.admin.OffsetSpec$EarliestSpec.class org.apache.kafka.clients.admin.CreatePartitionsOptions.class org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupOptions.class org.apache.kafka.clients.admin.ListConsumerGroupsResult.class org.apache.kafka.clients.admin.DeleteRecordsOptions.class org.apache.kafka.clients.admin.KafkaAdminClient$16.class org.apache.kafka.clients.admin.AlterConfigsOptions.class org.apache.kafka.clients.admin.ExpireDelegationTokenResult.class org.apache.kafka.clients.admin.CreateAclsOptions.class org.apache.kafka.clients.admin.KafkaAdminClient$32.class org.apache.kafka.clients.admin.ListTopicsOptions.class org.apache.kafka.clients.admin.ElectLeadersOptions.class org.apache.kafka.clients.admin.CreateTopicsResult.class org.apache.kafka.clients.admin.KafkaAdminClient$8.class org.apache.kafka.clients.admin.AlterConfigOp$OpType.class org.apache.kafka.clients.admin.ListOffsetsResult$1.class org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult$1.class org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsOptions.class org.apache.kafka.clients.admin.DescribeConsumerGroupsResult$1.class org.apache.kafka.clients.admin.ConfigEntry.class org.apache.kafka.clients.admin.OffsetSpec.class org.apache.kafka.clients.admin.KafkaAdminClient$12.class org.apache.kafka.clients.admin.CreatePartitionsResult.class org.apache.kafka.clients.admin.PartitionReassignment.class org.apache.kafka.clients.admin.ElectPreferredLeadersResult$2.class org.apache.kafka.clients.admin.MemberDescription.class org.apache.kafka.clients.admin.AlterReplicaLogDirsOptions.class org.apache.kafka.clients.admin.CreateTopicsResult$TopicMetadataAndConfig.class org.apache.kafka.clients.admin.KafkaAdminClient$10.class org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupResult.class org.apache.kafka.clients.admin.RenewDelegationTokenResult.class org.apache.kafka.clients.admin.DescribeConfigsResult.class org.apache.kafka.clients.admin.KafkaAdminClient$34.class org.apache.kafka.clients.admin.OffsetSpec$TimestampSpec.class org.apache.kafka.clients.admin.DescribeAclsOptions.class org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult.class org.apache.kafka.clients.admin.KafkaAdminClient.class org.apache.kafka.clients.admin.KafkaAdminClient$17.class org.apache.kafka.clients.admin.DescribeConfigsResult$1.class org.apache.kafka.clients.admin.KafkaAdminClient$9.class org.apache.kafka.clients.admin.KafkaAdminClient$25$1.class org.apache.kafka.clients.admin.TopicDescription.class org.apache.kafka.clients.admin.KafkaAdminClient$33.class org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable$1.class org.apache.kafka.clients.admin.KafkaAdminClient$31.class org.apache.kafka.clients.admin.DescribeConsumerGroupsResult.class org.apache.kafka.clients.admin.ConsumerGroupDescription.class org.apache.kafka.clients.admin.MemberAssignment.class org.apache.kafka.clients.admin.CreateDelegationTokenOptions.class org.apache.kafka.clients.admin.DescribeTopicsResult.class org.apache.kafka.clients.admin.KafkaAdminClient$28.class org.apache.kafka.clients.admin.KafkaAdminClient$15.class org.apache.kafka.clients.admin.AlterPartitionReassignmentsResult.class org.apache.kafka.clients.admin.ElectPreferredLeadersResult$1.class org.apache.kafka.clients.admin.AdminClientConfig.class org.apache.kafka.clients.admin.KafkaAdminClient$11.class org.apache.kafka.clients.admin.KafkaAdminClient$35.class org.apache.kafka.clients.admin.CreateAclsResult.class org.apache.kafka.clients.admin.AlterPartitionReassignmentsOptions.class org.apache.kafka.clients.admin.DeleteAclsResult.class org.apache.kafka.clients.admin.KafkaAdminClient$Call.class org.apache.kafka.clients.admin.DeleteAclsResult$FilterResults.class org.apache.kafka.clients.admin.ListOffsetsResult$ListOffsetsResultInfo.class org.apache.kafka.clients.admin.ListConsumerGroupsResult$1.class org.apache.kafka.clients.admin.ElectPreferredLeadersResult.class org.apache.kafka.clients.admin.ListConsumerGroupOffsetsOptions.class org.apache.kafka.clients.admin.KafkaAdminClient$13.class org.apache.kafka.clients.admin.KafkaAdminClient$TimeoutProcessor.class org.apache.kafka.clients.admin.DescribeClusterOptions.class org.apache.kafka.clients.admin.DescribeAclsResult.class org.apache.kafka.clients.admin.AlterConfigOp.class org.apache.kafka.clients.Metadata$1.class org.apache.kafka.clients.StaleMetadataException.class org.apache.kafka.clients.MetadataCache.class org.apache.kafka.clients.ClientRequest.class org.apache.kafka.clients.NetworkClientUtils.class org.apache.kafka.clients.ManualMetadataUpdater.class org.apache.kafka.clients.KafkaClient.class org.apache.kafka.clients.ClusterConnectionStates.class org.apache.kafka.clients.NetworkClient$1.class org.apache.kafka.clients.ClusterConnectionStates$1.class org.apache.kafka.clients.InFlightRequests.class org.apache.kafka.clients.NetworkClient$InFlightRequest.class org.apache.kafka.clients.NodeApiVersions.class org.apache.kafka.clients.Metadata$MetadataRequestAndVersion.class org.apache.kafka.clients.ClientDnsLookup.class org.apache.kafka.clients.GroupRebalanceConfig.class org.apache.kafka.clients.Metadata$LeaderAndEpoch.class org.apache.kafka.clients.consumer.RangeAssignor.class org.apache.kafka.clients.consumer.OffsetAndMetadata.class org.apache.kafka.clients.consumer.Consumer.class org.apache.kafka.clients.consumer.ConsumerInterceptor.class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$RebalanceProtocol.class org.apache.kafka.clients.consumer.RoundRobinAssignor.class org.apache.kafka.clients.consumer.MockConsumer.class org.apache.kafka.clients.consumer.OffsetAndTimestamp.class org.apache.kafka.clients.consumer.ConsumerConfig.class org.apache.kafka.clients.consumer.StickyAssignor.class org.apache.kafka.clients.consumer.CommitFailedException.class org.apache.kafka.clients.consumer.RetriableCommitFailedException.class org.apache.kafka.clients.consumer.ConsumerRecords$ConcatenatedIterable$1.class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$Assignment.class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$Subscription.class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$GroupAssignment.class org.apache.kafka.clients.consumer.KafkaConsumer.class org.apache.kafka.clients.consumer.CooperativeStickyAssignor.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$PendingCommittedOffsetRequest.class org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$MemberData.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetFetchResponseHandler.class org.apache.kafka.clients.consumer.internals.PartitionAssignorAdapter.class org.apache.kafka.clients.consumer.internals.RequestFuture$1.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$2.class org.apache.kafka.clients.consumer.internals.SubscriptionState$SubscriptionType.class org.apache.kafka.clients.consumer.internals.SubscriptionState$FetchStates$4.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$2.class org.apache.kafka.clients.consumer.internals.Fetcher$5.class org.apache.kafka.clients.consumer.internals.SubscriptionState$1.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$LeaveGroupResponseHandler.class org.apache.kafka.clients.consumer.internals.PartitionAssignor$Subscription.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatResponseHandler.class org.apache.kafka.clients.consumer.internals.SubscriptionState$FetchStates$2.class org.apache.kafka.clients.consumer.internals.SubscriptionState$TopicPartitionState.class org.apache.kafka.clients.consumer.internals.Heartbeat.class org.apache.kafka.clients.consumer.internals.ConsumerMetadata.class org.apache.kafka.clients.consumer.internals.RequestFuture.class org.apache.kafka.clients.consumer.internals.Fetcher$3.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$UnjoinedGroupException.class org.apache.kafka.clients.consumer.internals.Fetcher$FetchResponseMetricAggregator$FetchMetrics.class org.apache.kafka.clients.consumer.internals.Fetcher$1.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.class org.apache.kafka.clients.consumer.internals.ConsumerProtocol.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$1.class org.apache.kafka.clients.consumer.internals.Fetcher$6.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$PollCondition.class org.apache.kafka.clients.consumer.internals.RequestFuture$2.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$1.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$FindCoordinatorResponseHandler.class org.apache.kafka.clients.consumer.internals.Fetcher$CompletedFetch.class org.apache.kafka.clients.consumer.internals.PartitionAssignor.class org.apache.kafka.clients.consumer.internals.PartitionAssignor$Assignment.class org.apache.kafka.clients.consumer.internals.Fetcher$4.class org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochClient$OffsetForEpochResult.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$3.class org.apache.kafka.clients.consumer.internals.Fetcher$FetchResponseMetricAggregator.class org.apache.kafka.clients.consumer.internals.SubscriptionState.class org.apache.kafka.clients.consumer.internals.SubscriptionState$FetchStates$1.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$MemberState.class org.apache.kafka.clients.consumer.internals.Fetcher$FetchManagerMetrics.class org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$PartitionMovements.class org.apache.kafka.clients.consumer.internals.Fetcher$ListOffsetResult.class org.apache.kafka.clients.consumer.internals.SubscriptionState$FetchStates$3.class org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$ConsumerPair.class org.apache.kafka.clients.consumer.internals.Fetcher$2.class org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$SubscriptionComparator.class org.apache.kafka.clients.consumer.internals.RequestFutureListener.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$1.class org.apache.kafka.clients.consumer.internals.AsyncClient$1.class org.apache.kafka.clients.consumer.internals.KafkaConsumerMetrics.class org.apache.kafka.clients.consumer.internals.ConsumerMetrics.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests.class org.apache.kafka.clients.consumer.internals.ConsumerInterceptors.class org.apache.kafka.clients.consumer.internals.NoOpConsumerRebalanceListener.class org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor$MemberInfo.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.class org.apache.kafka.clients.consumer.internals.SubscriptionState$FetchState.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$Generation.class org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.class org.apache.kafka.clients.consumer.internals.SubscriptionState$FetchPosition.class org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.class org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochClient$1.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$DefaultOffsetCommitCallback.class org.apache.kafka.clients.consumer.internals.Fetcher$ListOffsetData.class org.apache.kafka.clients.consumer.internals.RequestFutureAdapter.class org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor.class org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$ConsumerGenerationPair.class org.apache.kafka.clients.consumer.internals.Fetcher.class org.apache.kafka.clients.consumer.internals.SubscriptionState$FetchStates.class org.apache.kafka.clients.consumer.internals.FetcherMetricsRegistry.class org.apache.kafka.clients.consumer.internals.OffsetsForLeaderEpochClient.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitCompletion.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread$1.class org.apache.kafka.clients.consumer.internals.NoAvailableBrokersException.class org.apache.kafka.clients.consumer.internals.AsyncClient.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$ConsumerCoordinatorMetrics.class org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$PartitionComparator.class org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$MetadataSnapshot.class org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$1.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$GroupCoordinatorMetrics.class org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.class org.apache.kafka.clients.consumer.ConsumerRecord.class org.apache.kafka.clients.consumer.LogTruncationException.class org.apache.kafka.clients.consumer.OffsetCommitCallback.class org.apache.kafka.clients.consumer.ConsumerRebalanceListener.class org.apache.kafka.clients.consumer.ConsumerRecords$ConcatenatedIterable.class org.apache.kafka.clients.consumer.OffsetOutOfRangeException.class org.apache.kafka.clients.consumer.ConsumerRecords.class org.apache.kafka.clients.consumer.OffsetResetStrategy.class org.apache.kafka.clients.consumer.ConsumerGroupMetadata.class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor$GroupSubscription.class org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.class org.apache.kafka.clients.consumer.NoOffsetForPartitionException.class org.apache.kafka.clients.consumer.InvalidOffsetException.class org.apache.kafka.clients.GroupRebalanceConfig$ProtocolType.class org.apache.kafka.clients.MetadataUpdater.class org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.class org.apache.kafka.clients.ClientResponse.class org.apache.kafka.server.authorizer.AclCreateResult.class org.apache.kafka.server.authorizer.AclDeleteResult.class org.apache.kafka.server.authorizer.AuthorizerServerInfo.class org.apache.kafka.server.authorizer.Authorizer.class org.apache.kafka.server.authorizer.AuthorizableRequestContext.class org.apache.kafka.server.authorizer.AuthorizationResult.class org.apache.kafka.server.authorizer.Action.class org.apache.kafka.server.authorizer.AclDeleteResult$AclBindingDeleteResult.class org.apache.kafka.server.quota.ClientQuotaEntity.class org.apache.kafka.server.quota.ClientQuotaType.class org.apache.kafka.server.quota.ClientQuotaEntity$ConfigEntity.class org.apache.kafka.server.quota.ClientQuotaEntity$ConfigEntityType.class org.apache.kafka.server.quota.ClientQuotaCallback.class org.apache.kafka.server.policy.AlterConfigPolicy.class org.apache.kafka.server.policy.AlterConfigPolicy$RequestMetadata.class org.apache.kafka.server.policy.CreateTopicPolicy.class org.apache.kafka.server.policy.CreateTopicPolicy$RequestMetadata.class org.apache.kafka.common.MetricName.class org.apache.kafka.common.KafkaFuture$BaseFunction.class org.apache.kafka.common.InvalidRecordException.class org.apache.kafka.common.KafkaFuture$Function.class org.apache.kafka.common.metrics.KafkaMetric.class org.apache.kafka.common.metrics.CompoundStat$NamedMeasurable.class org.apache.kafka.common.metrics.Measurable.class org.apache.kafka.common.metrics.CompoundStat.class org.apache.kafka.common.metrics.MetricValueProvider.class org.apache.kafka.common.metrics.QuotaViolationException.class org.apache.kafka.common.metrics.Quota.class org.apache.kafka.common.metrics.Sensor.class org.apache.kafka.common.metrics.MetricConfig.class org.apache.kafka.common.metrics.Sensor$RecordingLevel.class org.apache.kafka.common.metrics.JmxReporter.class org.apache.kafka.common.metrics.internals.IntGaugeSuite$StoredIntGauge.class org.apache.kafka.common.metrics.internals.IntGaugeSuite$PendingMetricsChange.class org.apache.kafka.common.metrics.internals.IntGaugeSuite.class org.apache.kafka.common.metrics.Metrics$ExpireSensorTask.class org.apache.kafka.common.metrics.Metrics.class org.apache.kafka.common.metrics.MetricsReporter.class org.apache.kafka.common.metrics.Stat.class org.apache.kafka.common.metrics.JmxReporter$KafkaMbean.class org.apache.kafka.common.metrics.MeasurableStat.class org.apache.kafka.common.metrics.Gauge.class org.apache.kafka.common.metrics.stats.Rate$1.class org.apache.kafka.common.metrics.stats.CumulativeCount.class org.apache.kafka.common.metrics.stats.SampledStat$Sample.class org.apache.kafka.common.metrics.stats.Percentiles$1.class org.apache.kafka.common.metrics.stats.Histogram$BinScheme.class org.apache.kafka.common.metrics.stats.Frequencies$1.class org.apache.kafka.common.metrics.stats.Max.class org.apache.kafka.common.metrics.stats.Frequencies$HistogramSample.class org.apache.kafka.common.metrics.stats.Histogram$ConstantBinScheme.class org.apache.kafka.common.metrics.stats.SampledStat.class org.apache.kafka.common.metrics.stats.CumulativeSum.class org.apache.kafka.common.metrics.stats.WindowedCount.class org.apache.kafka.common.metrics.stats.Histogram.class org.apache.kafka.common.metrics.stats.WindowedSum.class org.apache.kafka.common.metrics.stats.Avg.class org.apache.kafka.common.metrics.stats.Frequency.class org.apache.kafka.common.metrics.stats.Sum.class org.apache.kafka.common.metrics.stats.Rate.class org.apache.kafka.common.metrics.stats.Percentiles$HistogramSample.class org.apache.kafka.common.metrics.stats.Frequencies.class org.apache.kafka.common.metrics.stats.Count.class org.apache.kafka.common.metrics.stats.Meter.class org.apache.kafka.common.metrics.stats.Percentiles$BucketSizing.class org.apache.kafka.common.metrics.stats.SimpleRate.class org.apache.kafka.common.metrics.stats.Histogram$LinearBinScheme.class org.apache.kafka.common.metrics.stats.Min.class org.apache.kafka.common.metrics.stats.Rate$SampledTotal.class org.apache.kafka.common.metrics.stats.Value.class org.apache.kafka.common.metrics.stats.Percentile.class org.apache.kafka.common.metrics.stats.Percentiles.class org.apache.kafka.common.metrics.stats.Total.class org.apache.kafka.common.ClusterResource.class org.apache.kafka.common.Metric.class org.apache.kafka.common.ElectionType.class org.apache.kafka.common.IsolationLevel.class org.apache.kafka.common.ConsumerGroupState.class org.apache.kafka.common.record.RecordsUtil$RecordBatchAndRecords.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$1.class org.apache.kafka.common.record.DefaultRecordBatch$2.class org.apache.kafka.common.record.ByteBufferLogInputStream.class org.apache.kafka.common.record.LazyDownConversionRecords$1.class org.apache.kafka.common.record.AbstractRecordBatch.class org.apache.kafka.common.record.RecordsSend.class org.apache.kafka.common.record.DefaultRecordBatch$StreamRecordIterator.class org.apache.kafka.common.record.CompressionType$ZstdConstructors.class org.apache.kafka.common.record.MemoryRecords$RecordFilter.class org.apache.kafka.common.record.DefaultRecordBatch$RecordIterator.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$LegacyFileChannelRecordBatch.class org.apache.kafka.common.record.BufferSupplier$1.class org.apache.kafka.common.record.BaseRecords.class org.apache.kafka.common.record.ConvertedRecords.class org.apache.kafka.common.record.BufferSupplier.class org.apache.kafka.common.record.MultiRecordsSend.class org.apache.kafka.common.record.MemoryRecordsBuilder.class org.apache.kafka.common.record.DefaultRecordBatch$1.class org.apache.kafka.common.record.LazyDownConversionRecords.class org.apache.kafka.common.record.DefaultRecordBatch$3.class org.apache.kafka.common.record.LazyDownConversionRecordsSend.class org.apache.kafka.common.record.RecordBatch.class org.apache.kafka.common.record.MemoryRecords$1.class org.apache.kafka.common.record.FileLogInputStream$FileChannelRecordBatch.class org.apache.kafka.common.record.MemoryRecordsBuilder$RecordsInfo.class org.apache.kafka.common.record.FileRecords$LogOffsetPosition.class org.apache.kafka.common.record.MemoryRecords$RecordFilter$BatchRetention.class org.apache.kafka.common.record.DefaultRecordBatch$DefaultFileChannelRecordBatch.class org.apache.kafka.common.record.MutableRecordBatch.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$DataLogInputStream.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$BasicLegacyRecordBatch.class org.apache.kafka.common.record.Records.class org.apache.kafka.common.record.DefaultRecordBatch.class org.apache.kafka.common.record.CompressionType$5.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$DeepRecordsIterator.class org.apache.kafka.common.record.EndTransactionMarker.class org.apache.kafka.common.record.KafkaLZ4BlockOutputStream$BD.class org.apache.kafka.common.record.MemoryRecordsBuilder$1.class org.apache.kafka.common.record.KafkaLZ4BlockOutputStream$FLG.class org.apache.kafka.common.record.KafkaLZ4BlockOutputStream.class org.apache.kafka.common.record.CompressionType.class org.apache.kafka.common.record.MemoryRecords$FilterResult.class org.apache.kafka.common.record.PartialDefaultRecord.class org.apache.kafka.common.record.KafkaLZ4BlockInputStream.class org.apache.kafka.common.record.CompressionType$3.class org.apache.kafka.common.record.MemoryRecords.class org.apache.kafka.common.record.LogInputStream.class org.apache.kafka.common.record.CompressionType$1.class org.apache.kafka.common.record.RecordsUtil$1.class org.apache.kafka.common.record.BufferSupplier$DefaultSupplier.class org.apache.kafka.common.record.RecordsUtil.class org.apache.kafka.common.record.CompressionRatioEstimator.class org.apache.kafka.common.record.DefaultRecordsSend.class org.apache.kafka.common.record.FileRecords.class org.apache.kafka.common.record.RecordBatchIterator.class org.apache.kafka.common.record.CompressionType$SnappyConstructors.class org.apache.kafka.common.record.AbstractRecords$1.class org.apache.kafka.common.record.LazyDownConversionRecords$Iterator.class org.apache.kafka.common.record.RecordVersion.class org.apache.kafka.common.record.BufferSupplier$GrowableBufferSupplier.class org.apache.kafka.common.record.Record.class org.apache.kafka.common.record.CompressionType$4.class org.apache.kafka.common.record.FileLogInputStream.class org.apache.kafka.common.record.AbstractRecords.class org.apache.kafka.common.record.LegacyRecord.class org.apache.kafka.common.record.RecordConversionStats.class org.apache.kafka.common.record.DefaultRecord.class org.apache.kafka.common.record.ControlRecordType.class org.apache.kafka.common.record.AbstractLegacyRecordBatch.class org.apache.kafka.common.record.AbstractLegacyRecordBatch$ByteBufferLegacyRecordBatch.class org.apache.kafka.common.record.TimestampType.class org.apache.kafka.common.record.FileRecords$TimestampAndOffset.class org.apache.kafka.common.record.SimpleRecord.class org.apache.kafka.common.record.CompressionType$2.class org.apache.kafka.common.KafkaFuture$AllOfAdapter.class org.apache.kafka.common.memory.GarbageCollectedMemoryPool$1.class org.apache.kafka.common.memory.MemoryPool.class org.apache.kafka.common.memory.SimpleMemoryPool.class org.apache.kafka.common.memory.GarbageCollectedMemoryPool$GarbageCollectionListener.class org.apache.kafka.common.memory.MemoryPool$1.class org.apache.kafka.common.memory.GarbageCollectedMemoryPool$BufferReference.class org.apache.kafka.common.memory.GarbageCollectedMemoryPool.class org.apache.kafka.common.memory.GarbageCollectedMemoryPool$BufferMetadata.class org.apache.kafka.common.PartitionInfo.class org.apache.kafka.common.cache.SynchronizedCache.class org.apache.kafka.common.cache.LRUCache.class org.apache.kafka.common.cache.LRUCache$1.class org.apache.kafka.common.cache.Cache.class org.apache.kafka.common.config.SaslConfigs.class org.apache.kafka.common.config.ConfigResource$Type.class org.apache.kafka.common.config.ConfigDef.class org.apache.kafka.common.config.types.Password.class org.apache.kafka.common.config.ConfigValue.class org.apache.kafka.common.config.ConfigDef$Importance.class org.apache.kafka.common.config.AbstractConfig.class org.apache.kafka.common.config.ConfigDef$CompositeValidator.class org.apache.kafka.common.config.provider.FileConfigProvider.class org.apache.kafka.common.config.provider.ConfigProvider.class org.apache.kafka.common.config.ConfigDef$Validator.class org.apache.kafka.common.config.ConfigData.class org.apache.kafka.common.config.Config.class org.apache.kafka.common.config.ConfigDef$ValidString.class org.apache.kafka.common.config.ConfigDef$ValidList.class org.apache.kafka.common.config.ConfigDef$CaseInsensitiveValidString.class org.apache.kafka.common.config.ConfigDef$NonEmptyStringWithoutControlChars.class org.apache.kafka.common.config.ConfigChangeCallback.class org.apache.kafka.common.config.internals.BrokerSecurityConfigs.class org.apache.kafka.common.config.ConfigException.class org.apache.kafka.common.config.ConfigDef$LambdaValidator.class org.apache.kafka.common.config.ConfigTransformerResult.class org.apache.kafka.common.config.ConfigTransformer$ConfigVariable.class org.apache.kafka.common.config.AbstractConfig$RecordingMap.class org.apache.kafka.common.config.ConfigDef$Type.class org.apache.kafka.common.config.ConfigDef$2.class org.apache.kafka.common.config.AbstractConfig$ResolvingMap.class org.apache.kafka.common.config.ConfigDef$Width.class org.apache.kafka.common.config.TopicConfig.class org.apache.kafka.common.config.SecurityConfig.class org.apache.kafka.common.config.ConfigDef$ConfigKey.class org.apache.kafka.common.config.ConfigTransformer.class org.apache.kafka.common.config.ConfigDef$Range.class org.apache.kafka.common.config.ConfigDef$Recommender.class org.apache.kafka.common.config.SslClientAuth.class org.apache.kafka.common.config.ConfigDef$NonEmptyString.class org.apache.kafka.common.config.ConfigDef$NonNullValidator.class org.apache.kafka.common.config.SslConfigs.class org.apache.kafka.common.config.ConfigDef$1.class org.apache.kafka.common.config.ConfigDef$3.class org.apache.kafka.common.config.LogLevelConfig.class org.apache.kafka.common.config.ConfigResource.class org.apache.kafka.common.security.token.delegation.internals.DelegationTokenCredentialCallback.class org.apache.kafka.common.security.token.delegation.internals.DelegationTokenCache.class org.apache.kafka.common.security.token.delegation.TokenInformation.class org.apache.kafka.common.security.token.delegation.DelegationToken.class org.apache.kafka.common.security.kerberos.KerberosLogin.class org.apache.kafka.common.security.kerberos.KerberosError.class org.apache.kafka.common.security.kerberos.NoMatchingRule.class org.apache.kafka.common.security.kerberos.KerberosRule.class org.apache.kafka.common.security.kerberos.KerberosShortNamer.class org.apache.kafka.common.security.kerberos.KerberosName.class org.apache.kafka.common.security.kerberos.BadFormatString.class org.apache.kafka.common.security.kerberos.KerberosClientCallbackHandler.class org.apache.kafka.common.security.ssl.SslEngineBuilder$1.class org.apache.kafka.common.security.ssl.SslPrincipalMapper$NoMatchingRule.class org.apache.kafka.common.security.ssl.SslFactory$SslEngineValidator.class org.apache.kafka.common.security.ssl.SslPrincipalMapper.class org.apache.kafka.common.security.ssl.SslFactory$1.class org.apache.kafka.common.security.ssl.SslFactory.class org.apache.kafka.common.security.ssl.SslEngineBuilder$SecurityStore.class org.apache.kafka.common.security.ssl.SslEngineBuilder.class org.apache.kafka.common.security.ssl.SslPrincipalMapper$Rule.class org.apache.kafka.common.security.ssl.SslFactory$CertificateEntries.class org.apache.kafka.common.security.JaasConfig.class org.apache.kafka.common.security.auth.SecurityProtocol.class org.apache.kafka.common.security.auth.KafkaPrincipal.class org.apache.kafka.common.security.auth.AuthenticateCallbackHandler.class org.apache.kafka.common.security.auth.KafkaPrincipalBuilder.class org.apache.kafka.common.security.auth.Login.class org.apache.kafka.common.security.auth.DefaultPrincipalBuilder.class org.apache.kafka.common.security.auth.SaslExtensionsCallback.class org.apache.kafka.common.security.auth.SaslExtensions.class org.apache.kafka.common.security.auth.PlaintextAuthenticationContext.class org.apache.kafka.common.security.auth.SecurityProviderCreator.class org.apache.kafka.common.security.auth.SaslAuthenticationContext.class org.apache.kafka.common.security.auth.PrincipalBuilder.class org.apache.kafka.common.security.auth.AuthenticationContext.class org.apache.kafka.common.security.auth.SslAuthenticationContext.class org.apache.kafka.common.security.plain.PlainAuthenticateCallback.class org.apache.kafka.common.security.plain.internals.PlainSaslServerProvider.class org.apache.kafka.common.security.plain.internals.PlainServerCallbackHandler.class org.apache.kafka.common.security.plain.internals.PlainSaslServer$PlainSaslServerFactory.class org.apache.kafka.common.security.plain.internals.PlainSaslServer.class org.apache.kafka.common.security.plain.PlainLoginModule.class org.apache.kafka.common.security.JaasUtils.class org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallback.class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule$LoginState.class org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallback.class org.apache.kafka.common.security.oauthbearer.OAuthBearerExtensionsValidatorCallback.class org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClient$State.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClientCallbackHandler$1.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClientCallbackHandler.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClientProvider.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredLoginCallbackHandler.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredValidatorCallbackHandler.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerConfigException.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerScopeUtils.class org.apache.kafka.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationUtils.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerClientInitialResponse.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClient.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClient$OAuthBearerSaslClientFactory.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslServer.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslServerProvider.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerRefreshingLogin$1.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslServer$OAuthBearerSaslServerFactory.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerRefreshingLogin.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerSaslClient$1.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLogin$1.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredential.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLogin$ExitRefresherThreadDueToIllegalStateException.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLogin$LoginContextFactory.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLogin$Refresher.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshConfig.class org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLogin.class org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerRefreshingLogin$1$1.class org.apache.kafka.common.security.oauthbearer.OAuthBearerToken.class org.apache.kafka.common.security.JaasContext.class org.apache.kafka.common.security.scram.ScramCredentialCallback.class org.apache.kafka.common.security.scram.internals.ScramExtensions.class org.apache.kafka.common.security.scram.internals.ScramMessages$AbstractScramMessage.class org.apache.kafka.common.security.scram.internals.ScramMessages$ClientFinalMessage.class org.apache.kafka.common.security.scram.internals.ScramMessages$ServerFinalMessage.class org.apache.kafka.common.security.scram.internals.ScramSaslServerProvider.class org.apache.kafka.common.security.scram.internals.ScramSaslServer$ScramSaslServerFactory.class org.apache.kafka.common.security.scram.internals.ScramFormatter.class org.apache.kafka.common.security.scram.internals.ScramSaslClient.class org.apache.kafka.common.security.scram.internals.ScramSaslClient$1.class org.apache.kafka.common.security.scram.internals.ScramSaslClient$ScramSaslClientFactory.class org.apache.kafka.common.security.scram.internals.ScramSaslServer$State.class org.apache.kafka.common.security.scram.internals.ScramSaslServer.class org.apache.kafka.common.security.scram.internals.ScramCredentialUtils.class org.apache.kafka.common.security.scram.internals.ScramSaslServer$1.class org.apache.kafka.common.security.scram.internals.ScramMechanism.class org.apache.kafka.common.security.scram.internals.ScramSaslClientProvider.class org.apache.kafka.common.security.scram.internals.ScramSaslClient$State.class org.apache.kafka.common.security.scram.internals.ScramMessages.class org.apache.kafka.common.security.scram.internals.ScramMessages$ClientFirstMessage.class org.apache.kafka.common.security.scram.internals.ScramServerCallbackHandler.class org.apache.kafka.common.security.scram.internals.ScramMessages$ServerFirstMessage.class org.apache.kafka.common.security.scram.ScramCredential.class org.apache.kafka.common.security.scram.ScramExtensionsCallback.class org.apache.kafka.common.security.scram.ScramLoginModule.class org.apache.kafka.common.security.JaasContext$Type.class org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.class org.apache.kafka.common.security.authenticator.SaslServerAuthenticator.class org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$SaslState.class org.apache.kafka.common.security.authenticator.SaslClientAuthenticator$ReauthInfo.class org.apache.kafka.common.security.authenticator.SaslServerCallbackHandler.class org.apache.kafka.common.security.authenticator.AbstractLogin.class org.apache.kafka.common.security.authenticator.CredentialCache$Cache.class org.apache.kafka.common.security.authenticator.CredentialCache.class org.apache.kafka.common.security.authenticator.SaslClientAuthenticator$1.class org.apache.kafka.common.security.authenticator.LoginManager$LoginMetadata.class org.apache.kafka.common.security.authenticator.SaslClientCallbackHandler.class org.apache.kafka.common.security.authenticator.LoginManager.class org.apache.kafka.common.security.authenticator.SaslInternalConfigs.class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder.class org.apache.kafka.common.security.authenticator.DefaultLogin.class org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$1.class org.apache.kafka.common.security.authenticator.SaslClientAuthenticator$SaslState.class org.apache.kafka.common.security.authenticator.SaslServerAuthenticator$ReauthInfo.class org.apache.kafka.common.security.authenticator.AbstractLogin$DefaultLoginCallbackHandler.class org.apache.kafka.common.KafkaFuture.class org.apache.kafka.common.TopicPartitionReplica.class org.apache.kafka.common.Configurable.class org.apache.kafka.common.serialization.ShortDeserializer.class org.apache.kafka.common.serialization.VoidDeserializer.class org.apache.kafka.common.serialization.Serdes$BytesSerde.class org.apache.kafka.common.serialization.DoubleSerializer.class org.apache.kafka.common.serialization.LongSerializer.class org.apache.kafka.common.serialization.ExtendedDeserializer$Wrapper.class org.apache.kafka.common.serialization.Serdes$LongSerde.class org.apache.kafka.common.serialization.BytesDeserializer.class org.apache.kafka.common.serialization.StringDeserializer.class org.apache.kafka.common.serialization.Serdes$ByteBufferSerde.class org.apache.kafka.common.serialization.Serdes$DoubleSerde.class org.apache.kafka.common.serialization.ExtendedSerializer.class org.apache.kafka.common.serialization.BytesSerializer.class org.apache.kafka.common.serialization.Serde.class org.apache.kafka.common.serialization.UUIDSerializer.class org.apache.kafka.common.serialization.ByteArraySerializer.class org.apache.kafka.common.serialization.VoidSerializer.class org.apache.kafka.common.serialization.Serdes$ByteArraySerde.class org.apache.kafka.common.serialization.IntegerSerializer.class org.apache.kafka.common.serialization.ExtendedDeserializer.class org.apache.kafka.common.serialization.Serdes$UUIDSerde.class org.apache.kafka.common.serialization.ByteBufferSerializer.class org.apache.kafka.common.serialization.Serdes$FloatSerde.class org.apache.kafka.common.serialization.ByteArrayDeserializer.class org.apache.kafka.common.serialization.ExtendedSerializer$Wrapper.class org.apache.kafka.common.serialization.Serdes$ShortSerde.class org.apache.kafka.common.serialization.LongDeserializer.class org.apache.kafka.common.serialization.Serdes.class org.apache.kafka.common.serialization.Deserializer.class org.apache.kafka.common.serialization.FloatSerializer.class org.apache.kafka.common.serialization.FloatDeserializer.class org.apache.kafka.common.serialization.Serdes$WrapperSerde.class org.apache.kafka.common.serialization.Serdes$VoidSerde.class org.apache.kafka.common.serialization.UUIDDeserializer.class org.apache.kafka.common.serialization.ShortSerializer.class org.apache.kafka.common.serialization.Serializer.class org.apache.kafka.common.serialization.Serdes$StringSerde.class org.apache.kafka.common.serialization.Serdes$IntegerSerde.class org.apache.kafka.common.serialization.DoubleDeserializer.class org.apache.kafka.common.serialization.IntegerDeserializer.class org.apache.kafka.common.serialization.ByteBufferDeserializer.class org.apache.kafka.common.serialization.StringSerializer.class org.apache.kafka.common.network.SslChannelBuilder$SslAuthenticator.class org.apache.kafka.common.network.SslTransportLayer$State.class org.apache.kafka.common.network.PlaintextChannelBuilder.class org.apache.kafka.common.network.Selector$IdleExpiryManager.class org.apache.kafka.common.network.TransportLayers.class org.apache.kafka.common.network.CipherInformation.class org.apache.kafka.common.network.SslTransportLayer$1.class org.apache.kafka.common.network.Send.class org.apache.kafka.common.network.KafkaChannel.class org.apache.kafka.common.network.PlaintextChannelBuilder$PlaintextAuthenticator.class org.apache.kafka.common.network.Selector$SelectorMetrics.class org.apache.kafka.common.network.ChannelState.class org.apache.kafka.common.network.ByteBufferSend.class org.apache.kafka.common.network.Mode.class org.apache.kafka.common.network.Selector.class org.apache.kafka.common.network.DefaultChannelMetadataRegistry.class org.apache.kafka.common.network.KafkaChannel$1.class org.apache.kafka.common.network.ChannelBuilders.class org.apache.kafka.common.network.ListenerName.class org.apache.kafka.common.network.ClientInformation.class org.apache.kafka.common.network.SaslChannelBuilder.class org.apache.kafka.common.network.NetworkSend.class org.apache.kafka.common.network.ReauthenticationContext.class org.apache.kafka.common.network.PlaintextChannelBuilder$1.class org.apache.kafka.common.network.PlaintextTransportLayer.class org.apache.kafka.common.network.Selector$SelectorChannelMetadataRegistry.class org.apache.kafka.common.network.SslChannelBuilder$1.class org.apache.kafka.common.network.SslTransportLayer.class org.apache.kafka.common.network.InvalidReceiveException.class org.apache.kafka.common.network.Authenticator.class org.apache.kafka.common.network.TransportLayer.class org.apache.kafka.common.network.KafkaChannel$ChannelMuteState.class org.apache.kafka.common.network.NetworkReceive.class org.apache.kafka.common.network.ChannelMetadataRegistry.class org.apache.kafka.common.network.ChannelState$State.class org.apache.kafka.common.network.Selector$CloseMode.class org.apache.kafka.common.network.Selector$DelayedAuthenticationFailureClose.class org.apache.kafka.common.network.Selectable.class org.apache.kafka.common.network.ListenerReconfigurable.class org.apache.kafka.common.network.ChannelBuilders$1.class org.apache.kafka.common.network.Receive.class org.apache.kafka.common.network.SslChannelBuilder.class org.apache.kafka.common.network.DelayedResponseAuthenticationException.class org.apache.kafka.common.network.ChannelBuilder.class org.apache.kafka.common.network.KafkaChannel$ChannelMuteEvent.class org.apache.kafka.common.Reconfigurable.class org.apache.kafka.common.annotation.InterfaceStability$Evolving.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.message.ElectLeadersRequestData.class org.apache.kafka.common.message.FetchResponseData$AbortedTransaction.class org.apache.kafka.common.message.WriteTxnMarkersRequestData$WritableTxnMarkerTopic.class org.apache.kafka.common.message.ListOffsetResponseData$ListOffsetPartitionResponse.class org.apache.kafka.common.message.SaslAuthenticateResponseData.class org.apache.kafka.common.message.RenewDelegationTokenResponseData.class org.apache.kafka.common.message.FetchRequestData$ForgottenTopic.class org.apache.kafka.common.message.DescribeGroupsResponseData.class org.apache.kafka.common.message.DeleteAclsResponseData$DeleteAclsFilterResult.class org.apache.kafka.common.message.OffsetForLeaderEpochRequestData$OffsetForLeaderPartition.class org.apache.kafka.common.message.AlterConfigsRequestData.class org.apache.kafka.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResourceCollection.class org.apache.kafka.common.message.ListOffsetResponseData.class org.apache.kafka.common.message.IncrementalAlterConfigsRequestData$AlterConfigsResource.class org.apache.kafka.common.message.JoinGroupResponseData.class org.apache.kafka.common.message.MetadataRequestData$MetadataRequestTopic.class org.apache.kafka.common.message.DescribeDelegationTokenRequestData.class org.apache.kafka.common.message.DeleteRecordsRequestData$DeleteRecordsTopic.class org.apache.kafka.common.message.OffsetCommitResponseData$OffsetCommitResponsePartition.class org.apache.kafka.common.message.OffsetDeleteResponseData$OffsetDeleteResponsePartition.class org.apache.kafka.common.message.OffsetCommitResponseData.class org.apache.kafka.common.message.DescribeLogDirsResponseData.class org.apache.kafka.common.message.LeaveGroupRequestData.class org.apache.kafka.common.message.CreateAclsResponseData$AclCreationResult.class org.apache.kafka.common.message.CreateTopicsRequestData$CreateableTopicConfigCollection.class org.apache.kafka.common.message.UpdateMetadataRequestData$UpdateMetadataBroker.class org.apache.kafka.common.message.WriteTxnMarkersResponseData$WritableTxnMarkerTopicResult.class org.apache.kafka.common.message.OffsetFetchResponseData$OffsetFetchResponseTopic.class org.apache.kafka.common.message.ApiVersionsResponseData.class org.apache.kafka.common.message.LeaveGroupRequestData$MemberIdentity.class org.apache.kafka.common.message.DeleteGroupsResponseData.class org.apache.kafka.common.message.JoinGroupRequestData.class org.apache.kafka.common.message.AlterConfigsResponseData.class org.apache.kafka.common.message.CreatePartitionsResponseData$CreatePartitionsTopicResult.class org.apache.kafka.common.message.OffsetDeleteResponseData.class org.apache.kafka.common.message.ProduceResponseData$TopicProduceResponse.class org.apache.kafka.common.message.DeleteRecordsResponseData$DeleteRecordsTopicResult.class org.apache.kafka.common.message.OffsetDeleteRequestData$OffsetDeleteRequestTopic.class org.apache.kafka.common.message.HeartbeatResponseData.class org.apache.kafka.common.message.AlterPartitionReassignmentsRequestData.class org.apache.kafka.common.message.InitProducerIdRequestData.class org.apache.kafka.common.message.AlterConfigsResponseData$AlterConfigsResourceResponse.class org.apache.kafka.common.message.ApiVersionsResponseData$ApiVersionsResponseKey.class org.apache.kafka.common.message.DescribeConfigsResponseData$DescribeConfigsSynonym.class org.apache.kafka.common.message.ElectLeadersResponseData.class org.apache.kafka.common.message.AddPartitionsToTxnRequestData.class org.apache.kafka.common.message.DeleteGroupsResponseData$DeletableGroupResult.class org.apache.kafka.common.message.OffsetDeleteRequestData$OffsetDeleteRequestPartition.class org.apache.kafka.common.message.UpdateMetadataResponseData.class org.apache.kafka.common.message.ApiVersionsRequestData.class org.apache.kafka.common.message.ProduceRequestData$TopicProduceData.class org.apache.kafka.common.message.IncrementalAlterConfigsRequestData$AlterableConfigCollection.class org.apache.kafka.common.message.ListPartitionReassignmentsRequestData$ListPartitionReassignmentsTopics.class org.apache.kafka.common.message.AlterReplicaLogDirsResponseData$AlterReplicaLogDirTopicResult.class org.apache.kafka.common.message.OffsetForLeaderEpochRequestData.class org.apache.kafka.common.message.ListOffsetRequestData$ListOffsetTopic.class org.apache.kafka.common.message.RenewDelegationTokenRequestData.class org.apache.kafka.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment.class org.apache.kafka.common.message.UpdateMetadataRequestData$UpdateMetadataEndpoint.class org.apache.kafka.common.message.CreateTopicsResponseData$CreatableTopicResult.class org.apache.kafka.common.message.ProduceResponseData$BatchIndexAndErrorMessage.class org.apache.kafka.common.message.RequestHeaderData.class org.apache.kafka.common.message.HeartbeatRequestData.class org.apache.kafka.common.message.ExpireDelegationTokenRequestData.class org.apache.kafka.common.message.TxnOffsetCommitRequestData$TxnOffsetCommitRequestPartition.class org.apache.kafka.common.message.DescribeDelegationTokenResponseData$DescribedDelegationToken.class org.apache.kafka.common.message.SyncGroupRequestData$SyncGroupRequestAssignment.class org.apache.kafka.common.message.TxnOffsetCommitRequestData.class org.apache.kafka.common.message.TxnOffsetCommitResponseData$TxnOffsetCommitResponseTopic.class org.apache.kafka.common.message.IncrementalAlterConfigsResponseData.class org.apache.kafka.common.message.OffsetDeleteRequestData.class org.apache.kafka.common.message.DescribeDelegationTokenRequestData$DescribeDelegationTokenOwner.class org.apache.kafka.common.message.MetadataResponseData.class org.apache.kafka.common.message.CreateDelegationTokenResponseData.class org.apache.kafka.common.message.MetadataResponseData$MetadataResponsePartition.class org.apache.kafka.common.message.WriteTxnMarkersRequestData.class org.apache.kafka.common.message.TxnOffsetCommitResponseData.class org.apache.kafka.common.message.CreateTopicsResponseData$CreatableTopicResultCollection.class org.apache.kafka.common.message.StopReplicaRequestData.class org.apache.kafka.common.message.SaslHandshakeResponseData.class org.apache.kafka.common.message.ListPartitionReassignmentsResponseData$OngoingTopicReassignment.class org.apache.kafka.common.message.DescribeLogDirsRequestData$DescribableLogDirTopic.class org.apache.kafka.common.message.ListPartitionReassignmentsRequestData.class org.apache.kafka.common.message.CreatePartitionsRequestData$CreatePartitionsTopic.class org.apache.kafka.common.message.AlterReplicaLogDirsRequestData$AlterReplicaLogDirTopicCollection.class org.apache.kafka.common.message.ControlledShutdownResponseData$RemainingPartitionCollection.class org.apache.kafka.common.message.OffsetDeleteResponseData$OffsetDeleteResponsePartitionCollection.class org.apache.kafka.common.message.EndTxnRequestData.class org.apache.kafka.common.message.AlterReplicaLogDirsRequestData$AlterReplicaLogDirTopic.class org.apache.kafka.common.message.MetadataResponseData$MetadataResponseTopic.class org.apache.kafka.common.message.CreatePartitionsResponseData.class org.apache.kafka.common.message.DescribeConfigsResponseData$DescribeConfigsResult.class org.apache.kafka.common.message.OffsetForLeaderEpochResponseData$OffsetForLeaderPartitionResult.class org.apache.kafka.common.message.DescribeGroupsResponseData$DescribedGroup.class org.apache.kafka.common.message.CreatePartitionsRequestData$CreatePartitionsAssignment.class org.apache.kafka.common.message.OffsetFetchRequestData$OffsetFetchRequestTopic.class org.apache.kafka.common.message.OffsetCommitRequestData$OffsetCommitRequestTopic.class org.apache.kafka.common.message.CreateAclsResponseData.class org.apache.kafka.common.message.ProduceResponseData$PartitionProduceResponse.class org.apache.kafka.common.message.DescribeAclsResponseData$DescribeAclsResource.class org.apache.kafka.common.message.AddOffsetsToTxnRequestData.class org.apache.kafka.common.message.FindCoordinatorResponseData.class org.apache.kafka.common.message.LeaderAndIsrRequestData.class org.apache.kafka.common.message.ListGroupsResponseData$ListedGroup.class org.apache.kafka.common.message.AlterReplicaLogDirsRequestData.class org.apache.kafka.common.message.LeaveGroupResponseData$MemberResponse.class org.apache.kafka.common.message.DeleteTopicsResponseData.class org.apache.kafka.common.message.AlterConfigsRequestData$AlterConfigsResourceCollection.class org.apache.kafka.common.message.DeleteRecordsRequestData.class org.apache.kafka.common.message.CreateAclsRequestData$AclCreation.class org.apache.kafka.common.message.StopReplicaRequestData$StopReplicaTopic.class org.apache.kafka.common.message.ElectLeadersResponseData$ReplicaElectionResult.class org.apache.kafka.common.message.FindCoordinatorRequestData.class org.apache.kafka.common.message.OffsetForLeaderEpochResponseData.class org.apache.kafka.common.message.DeleteGroupsResponseData$DeletableGroupResultCollection.class org.apache.kafka.common.message.LeaderAndIsrRequestData$LeaderAndIsrLiveLeader.class org.apache.kafka.common.message.ProduceRequestData$PartitionProduceData.class org.apache.kafka.common.message.DeleteRecordsRequestData$DeleteRecordsPartition.class org.apache.kafka.common.message.AlterPartitionReassignmentsRequestData$ReassignableTopic.class org.apache.kafka.common.message.ElectLeadersResponseData$PartitionResult.class org.apache.kafka.common.message.CreateDelegationTokenRequestData.class org.apache.kafka.common.message.CreateTopicsResponseData$CreatableTopicConfigs.class org.apache.kafka.common.message.ListOffsetRequestData.class org.apache.kafka.common.message.OffsetDeleteRequestData$OffsetDeleteRequestTopicCollection.class org.apache.kafka.common.message.AlterConfigsRequestData$AlterableConfigCollection.class org.apache.kafka.common.message.MetadataResponseData$MetadataResponseTopicCollection.class org.apache.kafka.common.message.DeleteGroupsRequestData.class org.apache.kafka.common.message.CreateTopicsResponseData.class org.apache.kafka.common.message.AddOffsetsToTxnResponseData.class org.apache.kafka.common.message.ElectLeadersRequestData$TopicPartitions.class org.apache.kafka.common.message.SaslHandshakeRequestData.class org.apache.kafka.common.message.DescribeGroupsResponseData$DescribedGroupMember.class org.apache.kafka.common.message.OffsetForLeaderEpochRequestData$OffsetForLeaderTopic.class org.apache.kafka.common.message.DescribeAclsRequestData.class org.apache.kafka.common.message.ControlledShutdownRequestData.class org.apache.kafka.common.message.DeleteAclsResponseData.class org.apache.kafka.common.message.DescribeDelegationTokenResponseData.class org.apache.kafka.common.message.JoinGroupRequestData$JoinGroupRequestProtocolCollection.class org.apache.kafka.common.message.OffsetDeleteResponseData$OffsetDeleteResponseTopic.class org.apache.kafka.common.message.OffsetForLeaderEpochResponseData$OffsetForLeaderTopicResult.class org.apache.kafka.common.message.AddPartitionsToTxnResponseData$AddPartitionsToTxnTopicResult.class org.apache.kafka.common.message.CreateTopicsRequestData$CreatableReplicaAssignmentCollection.class org.apache.kafka.common.message.ProduceRequestData.class org.apache.kafka.common.message.DeleteAclsRequestData.class org.apache.kafka.common.message.DeleteAclsResponseData$DeleteAclsMatchingAcl.class org.apache.kafka.common.message.AddPartitionsToTxnResponseData$AddPartitionsToTxnPartitionResult.class org.apache.kafka.common.message.StopReplicaResponseData$StopReplicaPartitionError.class org.apache.kafka.common.message.ControlledShutdownResponseData$RemainingPartition.class org.apache.kafka.common.message.AddPartitionsToTxnResponseData$AddPartitionsToTxnTopicResultCollection.class org.apache.kafka.common.message.IncrementalAlterConfigsRequestData$AlterableConfig.class org.apache.kafka.common.message.OffsetFetchResponseData$OffsetFetchResponsePartition.class org.apache.kafka.common.message.CreateTopicsRequestData$CreateableTopicConfig.class org.apache.kafka.common.message.TxnOffsetCommitResponseData$TxnOffsetCommitResponsePartition.class org.apache.kafka.common.message.SaslAuthenticateRequestData.class org.apache.kafka.common.message.AlterReplicaLogDirsRequestData$AlterReplicaLogDirCollection.class org.apache.kafka.common.message.ListPartitionReassignmentsResponseData.class org.apache.kafka.common.message.DeleteRecordsResponseData$DeleteRecordsPartitionResult.class org.apache.kafka.common.message.LeaderAndIsrRequestData$LeaderAndIsrTopicState.class org.apache.kafka.common.message.OffsetDeleteResponseData$OffsetDeleteResponseTopicCollection.class org.apache.kafka.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition.class org.apache.kafka.common.message.StopReplicaResponseData.class org.apache.kafka.common.message.MetadataResponseData$MetadataResponseBrokerCollection.class org.apache.kafka.common.message.DescribeLogDirsResponseData$DescribeLogDirsTopic.class org.apache.kafka.common.message.AlterReplicaLogDirsRequestData$AlterReplicaLogDir.class org.apache.kafka.common.message.MetadataRequestData.class org.apache.kafka.common.message.DeleteTopicsResponseData$DeletableTopicResultCollection.class org.apache.kafka.common.message.DescribeDelegationTokenResponseData$DescribedDelegationTokenRenewer.class org.apache.kafka.common.message.DescribeConfigsResponseData$DescribeConfigsResourceResult.class org.apache.kafka.common.message.DeleteTopicsRequestData.class org.apache.kafka.common.message.CreateTopicsRequestData$CreatableReplicaAssignment.class org.apache.kafka.common.message.AddPartitionsToTxnResponseData$AddPartitionsToTxnPartitionResultCollection.class org.apache.kafka.common.message.WriteTxnMarkersResponseData$WritableTxnMarkerResult.class org.apache.kafka.common.message.UpdateMetadataRequestData.class org.apache.kafka.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState.class org.apache.kafka.common.message.FetchResponseData$FetchablePartitionResponse.class org.apache.kafka.common.message.ListGroupsRequestData.class org.apache.kafka.common.message.ListGroupsResponseData.class org.apache.kafka.common.message.ListOffsetResponseData$ListOffsetTopicResponse.class org.apache.kafka.common.message.OffsetCommitRequestData$OffsetCommitRequestPartition.class org.apache.kafka.common.message.IncrementalAlterConfigsRequestData.class org.apache.kafka.common.message.ExpireDelegationTokenResponseData.class org.apache.kafka.common.message.CreateTopicsRequestData$CreatableTopic.class org.apache.kafka.common.message.ApiVersionsResponseData$ApiVersionsResponseKeyCollection.class org.apache.kafka.common.message.ApiMessageType.class org.apache.kafka.common.message.CreateAclsRequestData.class org.apache.kafka.common.message.AlterPartitionReassignmentsResponseData$ReassignableTopicResponse.class org.apache.kafka.common.message.DeleteTopicsResponseData$DeletableTopicResult.class org.apache.kafka.common.message.EndTxnResponseData.class org.apache.kafka.common.message.LeaveGroupResponseData.class org.apache.kafka.common.message.IncrementalAlterConfigsResponseData$AlterConfigsResourceResponse.class org.apache.kafka.common.message.FetchResponseData.class org.apache.kafka.common.message.WriteTxnMarkersResponseData$WritableTxnMarkerPartitionResult.class org.apache.kafka.common.message.OffsetFetchRequestData.class org.apache.kafka.common.message.AlterPartitionReassignmentsResponseData.class org.apache.kafka.common.message.DescribeLogDirsResponseData$DescribeLogDirsResult.class org.apache.kafka.common.message.DescribeAclsResponseData$AclDescription.class org.apache.kafka.common.message.JoinGroupResponseData$JoinGroupResponseMember.class org.apache.kafka.common.message.WriteTxnMarkersResponseData.class org.apache.kafka.common.message.DeleteRecordsResponseData.class org.apache.kafka.common.message.CreateDelegationTokenRequestData$CreatableRenewers.class org.apache.kafka.common.message.FetchRequestData$FetchableTopic.class org.apache.kafka.common.message.FetchResponseData$FetchableTopicResponse.class org.apache.kafka.common.message.InitProducerIdResponseData.class org.apache.kafka.common.message.ResponseHeaderData.class org.apache.kafka.common.message.StopReplicaRequestData$StopReplicaPartitionV0.class org.apache.kafka.common.message.ListOffsetRequestData$ListOffsetPartition.class org.apache.kafka.common.message.MetadataResponseData$MetadataResponseBroker.class org.apache.kafka.common.message.CreatePartitionsRequestData.class org.apache.kafka.common.message.DescribeConfigsRequestData.class org.apache.kafka.common.message.OffsetCommitResponseData$OffsetCommitResponseTopic.class org.apache.kafka.common.message.AlterConfigsRequestData$AlterableConfig.class org.apache.kafka.common.message.DescribeConfigsRequestData$DescribeConfigsResource.class org.apache.kafka.common.message.AddPartitionsToTxnRequestData$AddPartitionsToTxnTopicCollection.class org.apache.kafka.common.message.LeaderAndIsrRequestData$LeaderAndIsrPartitionState.class org.apache.kafka.common.message.UpdateMetadataRequestData$UpdateMetadataTopicState.class org.apache.kafka.common.message.AlterPartitionReassignmentsRequestData$ReassignablePartition.class org.apache.kafka.common.message.DescribeConfigsResponseData.class org.apache.kafka.common.message.JoinGroupRequestData$JoinGroupRequestProtocol.class org.apache.kafka.common.message.CreateTopicsRequestData.class org.apache.kafka.common.message.TxnOffsetCommitRequestData$TxnOffsetCommitRequestTopic.class org.apache.kafka.common.message.OffsetFetchResponseData.class org.apache.kafka.common.message.FetchRequestData$FetchPartition.class org.apache.kafka.common.message.DescribeAclsResponseData.class org.apache.kafka.common.message.WriteTxnMarkersRequestData$WritableTxnMarker.class org.apache.kafka.common.message.FetchRequestData.class org.apache.kafka.common.message.ControlledShutdownResponseData.class org.apache.kafka.common.message.DescribeGroupsRequestData.class org.apache.kafka.common.message.LeaderAndIsrResponseData$LeaderAndIsrPartitionError.class org.apache.kafka.common.message.DeleteAclsRequestData$DeleteAclsFilter.class org.apache.kafka.common.message.AddPartitionsToTxnRequestData$AddPartitionsToTxnTopic.class org.apache.kafka.common.message.OffsetCommitRequestData.class org.apache.kafka.common.message.LeaderAndIsrResponseData.class org.apache.kafka.common.message.AlterReplicaLogDirsResponseData$AlterReplicaLogDirPartitionResult.class org.apache.kafka.common.message.AlterReplicaLogDirsResponseData.class org.apache.kafka.common.message.ProduceResponseData.class org.apache.kafka.common.message.AddPartitionsToTxnResponseData.class org.apache.kafka.common.message.AlterConfigsRequestData$AlterConfigsResource.class org.apache.kafka.common.message.SyncGroupRequestData.class org.apache.kafka.common.message.SyncGroupResponseData.class org.apache.kafka.common.message.CreateTopicsRequestData$CreatableTopicCollection.class org.apache.kafka.common.message.DescribeLogDirsRequestData.class org.apache.kafka.common.message.AlterPartitionReassignmentsResponseData$ReassignablePartitionResponse.class org.apache.kafka.common.utils.ThreadUtils.class org.apache.kafka.common.utils.LogContext$LocationAwareKafkaLogger.class org.apache.kafka.common.utils.Bytes$LexicographicByteArrayComparator.class org.apache.kafka.common.utils.Checksums.class org.apache.kafka.common.utils.CircularIterator.class org.apache.kafka.common.utils.PureJavaCrc32C.class org.apache.kafka.common.utils.Crc32C$1.class org.apache.kafka.common.utils.Crc32C$PureJavaChecksumFactory.class org.apache.kafka.common.utils.LoggingSignalHandler$1.class org.apache.kafka.common.utils.ImplicitLinkedHashCollection$ImplicitLinkedHashCollectionIterator.class org.apache.kafka.common.utils.Exit$ShutdownHookAdder.class org.apache.kafka.common.utils.Crc32C$Java9ChecksumFactory.class org.apache.kafka.common.utils.SystemTime.class org.apache.kafka.common.utils.LoggingSignalHandler.class org.apache.kafka.common.utils.Shell$ShellCommandExecutor.class org.apache.kafka.common.utils.AbstractIterator$State.class org.apache.kafka.common.utils.SecurityUtils.class org.apache.kafka.common.utils.CopyOnWriteMap.class org.apache.kafka.common.utils.LogContext.class org.apache.kafka.common.utils.Time.class org.apache.kafka.common.utils.PrimitiveRef.class org.apache.kafka.common.utils.CollectionUtils.class org.apache.kafka.common.utils.Bytes$1.class org.apache.kafka.common.utils.ImplicitLinkedHashCollection$HeadElement.class org.apache.kafka.common.utils.AbstractIterator$1.class org.apache.kafka.common.utils.MappedIterator.class org.apache.kafka.common.utils.FlattenedIterator.class org.apache.kafka.common.utils.CloseableIterator$1.class org.apache.kafka.common.utils.ImplicitLinkedHashCollection.class org.apache.kafka.common.utils.Timer.class org.apache.kafka.common.utils.Shell$ShellTimeoutTimerTask.class org.apache.kafka.common.utils.AbstractIterator.class org.apache.kafka.common.utils.Exit$Procedure.class org.apache.kafka.common.utils.KafkaThread.class org.apache.kafka.common.utils.ImplicitLinkedHashCollection$ImplicitLinkedHashCollectionListView.class org.apache.kafka.common.utils.ByteBufferOutputStream.class org.apache.kafka.common.utils.ImplicitLinkedHashCollection$ImplicitLinkedHashCollectionSetView.class org.apache.kafka.common.utils.Exit$3.class org.apache.kafka.common.utils.AppInfoParser$ImmutableValue.class org.apache.kafka.common.utils.AppInfoParser$AppInfo.class org.apache.kafka.common.utils.Crc32C$ChecksumFactory.class org.apache.kafka.common.utils.Exit$1.class org.apache.kafka.common.utils.OperatingSystem.class org.apache.kafka.common.utils.CloseableIterator.class org.apache.kafka.common.utils.Shell.class org.apache.kafka.common.utils.Bytes$ByteArrayComparator.class org.apache.kafka.common.utils.Shell$1.class org.apache.kafka.common.utils.Java$1.class org.apache.kafka.common.utils.Java$Version.class org.apache.kafka.common.utils.PrimitiveRef$IntRef.class org.apache.kafka.common.utils.LogContext$LocationIgnorantKafkaLogger.class org.apache.kafka.common.utils.ByteUtils.class org.apache.kafka.common.utils.AppInfoParser.class org.apache.kafka.common.utils.ImplicitLinkedHashCollection$Element.class org.apache.kafka.common.utils.Utils$1.class org.apache.kafka.common.utils.ByteBufferUnmapper.class org.apache.kafka.common.utils.SystemScheduler.class org.apache.kafka.common.utils.ProducerIdAndEpoch.class org.apache.kafka.common.utils.ThreadUtils$1.class org.apache.kafka.common.utils.Scheduler.class org.apache.kafka.common.utils.Java.class org.apache.kafka.common.utils.Exit.class org.apache.kafka.common.utils.Utils.class org.apache.kafka.common.utils.Exit$2.class org.apache.kafka.common.utils.ImplicitLinkedHashMultiCollection.class org.apache.kafka.common.utils.Crc32C.class org.apache.kafka.common.utils.ImplicitLinkedHashCollection$1.class org.apache.kafka.common.utils.AppInfoParser$AppInfoMBean.class org.apache.kafka.common.utils.Crc32.class org.apache.kafka.common.utils.Shell$ExitCodeException.class org.apache.kafka.common.utils.FixedOrderMap.class org.apache.kafka.common.utils.LogContext$AbstractKafkaLogger.class org.apache.kafka.common.utils.Utils$2.class org.apache.kafka.common.utils.Bytes.class org.apache.kafka.common.utils.Sanitizer.class org.apache.kafka.common.utils.ByteBufferInputStream.class org.apache.kafka.common.protocol.Protocol.class org.apache.kafka.common.protocol.Writable.class org.apache.kafka.common.protocol.types.Field$Int64.class org.apache.kafka.common.protocol.types.Field$ComplexArray.class org.apache.kafka.common.protocol.types.Type$3.class org.apache.kafka.common.protocol.types.Type$1.class org.apache.kafka.common.protocol.types.ArrayOf.class org.apache.kafka.common.protocol.types.Type$19.class org.apache.kafka.common.protocol.types.Type$5.class org.apache.kafka.common.protocol.types.Field$CompactNullableStr.class org.apache.kafka.common.protocol.types.Type$7.class org.apache.kafka.common.protocol.types.RawTaggedFieldWriter.class org.apache.kafka.common.protocol.types.TaggedFields.class org.apache.kafka.common.protocol.types.Type$DocumentedType.class org.apache.kafka.common.protocol.types.Type.class org.apache.kafka.common.protocol.types.Field$CompactStr.class org.apache.kafka.common.protocol.types.Type$2.class org.apache.kafka.common.protocol.types.Type$6.class org.apache.kafka.common.protocol.types.Field$TaggedFieldsSection.class org.apache.kafka.common.protocol.types.SchemaException.class org.apache.kafka.common.protocol.types.Field$Int8.class org.apache.kafka.common.protocol.types.Field$Bool.class org.apache.kafka.common.protocol.types.CompactArrayOf.class org.apache.kafka.common.protocol.types.Field.class org.apache.kafka.common.protocol.types.Type$4.class org.apache.kafka.common.protocol.types.Type$18.class org.apache.kafka.common.protocol.types.Type$8.class org.apache.kafka.common.protocol.types.Type$14.class org.apache.kafka.common.protocol.types.Field$CompactArray.class org.apache.kafka.common.protocol.types.Schema$Visitor.class org.apache.kafka.common.protocol.types.Field$Float64.class org.apache.kafka.common.protocol.types.Type$16.class org.apache.kafka.common.protocol.types.Type$12.class org.apache.kafka.common.protocol.types.Field$Array.class org.apache.kafka.common.protocol.types.BoundField.class org.apache.kafka.common.protocol.types.Schema.class org.apache.kafka.common.protocol.types.Type$10.class org.apache.kafka.common.protocol.types.Type$17.class org.apache.kafka.common.protocol.types.Field$Str.class org.apache.kafka.common.protocol.types.Field$Int32.class org.apache.kafka.common.protocol.types.Field$UUID.class org.apache.kafka.common.protocol.types.Field$NullableStr.class org.apache.kafka.common.protocol.types.Type$15.class org.apache.kafka.common.protocol.types.Type$9.class org.apache.kafka.common.protocol.types.Field$Int16.class org.apache.kafka.common.protocol.types.Struct.class org.apache.kafka.common.protocol.types.RawTaggedField.class org.apache.kafka.common.protocol.types.Type$11.class org.apache.kafka.common.protocol.types.Type$13.class org.apache.kafka.common.protocol.ApiKeys$1.class org.apache.kafka.common.protocol.ApiMessage.class org.apache.kafka.common.protocol.Message.class org.apache.kafka.common.protocol.ApiKeys.class org.apache.kafka.common.protocol.ApiKeys$2.class org.apache.kafka.common.protocol.MessageUtil.class org.apache.kafka.common.protocol.ByteBufferAccessor.class org.apache.kafka.common.protocol.ObjectSerializationCache.class org.apache.kafka.common.protocol.Readable.class org.apache.kafka.common.protocol.Errors.class org.apache.kafka.common.protocol.CommonFields.class org.apache.kafka.common.MetricNameTemplate.class org.apache.kafka.common.requests.LeaveGroupRequest$1.class org.apache.kafka.common.requests.FetchMetadata.class org.apache.kafka.common.requests.AlterConfigsResponse.class org.apache.kafka.common.requests.ListGroupsRequest$Builder.class org.apache.kafka.common.requests.AlterReplicaLogDirsRequest.class org.apache.kafka.common.requests.ListOffsetRequest$PartitionData.class org.apache.kafka.common.requests.ListOffsetRequest.class org.apache.kafka.common.requests.EndTxnRequest.class org.apache.kafka.common.requests.AbstractResponse.class org.apache.kafka.common.requests.ControlledShutdownRequest.class org.apache.kafka.common.requests.WriteTxnMarkersRequest.class org.apache.kafka.common.requests.AlterConfigsRequest$Config.class org.apache.kafka.common.requests.DeleteAclsRequest$1.class org.apache.kafka.common.requests.CreateAclsRequest$Builder.class org.apache.kafka.common.requests.ListPartitionReassignmentsRequest$Builder.class org.apache.kafka.common.requests.DescribeAclsRequest.class org.apache.kafka.common.requests.OffsetFetchResponse.class org.apache.kafka.common.requests.DescribeConfigsResponse$ConfigSynonym.class org.apache.kafka.common.requests.ListPartitionReassignmentsRequest$1.class org.apache.kafka.common.requests.StopReplicaResponse.class org.apache.kafka.common.requests.RequestUtils.class org.apache.kafka.common.requests.DescribeConfigsResponse$ConfigEntry.class org.apache.kafka.common.requests.MetadataRequest.class org.apache.kafka.common.requests.OffsetCommitRequest$Builder.class org.apache.kafka.common.requests.DescribeConfigsRequest$Builder.class org.apache.kafka.common.requests.SaslAuthenticateRequest$Builder.class org.apache.kafka.common.requests.CreateAclsResponse.class org.apache.kafka.common.requests.DescribeConfigsRequest.class org.apache.kafka.common.requests.DeleteAclsRequest$Builder.class org.apache.kafka.common.requests.InitProducerIdRequest$1.class org.apache.kafka.common.requests.CreateTopicsRequest$1.class org.apache.kafka.common.requests.ControlledShutdownRequest$1.class org.apache.kafka.common.requests.AbstractRequestResponse.class org.apache.kafka.common.requests.HeartbeatRequest$Builder.class org.apache.kafka.common.requests.DescribeGroupsRequest$Builder.class org.apache.kafka.common.requests.SaslAuthenticateRequest.class org.apache.kafka.common.requests.ListOffsetRequest$1.class org.apache.kafka.common.requests.ProduceResponse$RecordError.class org.apache.kafka.common.requests.ExpireDelegationTokenResponse.class org.apache.kafka.common.requests.ListPartitionReassignmentsRequest.class org.apache.kafka.common.requests.ElectLeadersRequest.class org.apache.kafka.common.requests.FetchRequest.class org.apache.kafka.common.requests.UpdateMetadataRequest.class org.apache.kafka.common.requests.CreateAclsRequest.class org.apache.kafka.common.requests.AlterConfigsRequest.class org.apache.kafka.common.requests.HeartbeatResponse.class org.apache.kafka.common.requests.ApiError.class org.apache.kafka.common.requests.LeaderAndIsrRequest$Builder.class org.apache.kafka.common.requests.FindCoordinatorRequest$1.class org.apache.kafka.common.requests.LeaderAndIsrRequest.class org.apache.kafka.common.requests.CreatePartitionsRequest.class org.apache.kafka.common.requests.ProduceResponse.class org.apache.kafka.common.requests.WriteTxnMarkersResponse.class org.apache.kafka.common.requests.SyncGroupRequest.class org.apache.kafka.common.requests.ApiVersionsRequest.class org.apache.kafka.common.requests.AbstractControlRequest.class org.apache.kafka.common.requests.DeleteGroupsRequest.class org.apache.kafka.common.requests.OffsetFetchRequest.class org.apache.kafka.common.requests.DeleteRecordsRequest.class org.apache.kafka.common.requests.DescribeDelegationTokenResponse.class org.apache.kafka.common.requests.DescribeGroupsResponse.class org.apache.kafka.common.requests.AbstractRequest$Builder.class org.apache.kafka.common.requests.ExpireDelegationTokenRequest$1.class org.apache.kafka.common.requests.DescribeAclsRequest$Builder.class org.apache.kafka.common.requests.MetadataResponse$TopicMetadata.class org.apache.kafka.common.requests.DescribeGroupsRequest$1.class org.apache.kafka.common.requests.AbstractRequest$1.class org.apache.kafka.common.requests.ListOffsetResponse.class org.apache.kafka.common.requests.OffsetsForLeaderEpochResponse.class org.apache.kafka.common.requests.AlterPartitionReassignmentsRequest.class org.apache.kafka.common.requests.DeleteTopicsRequest$1.class org.apache.kafka.common.requests.EndTxnRequest$1.class org.apache.kafka.common.requests.DescribeConfigsResponse.class org.apache.kafka.common.requests.DeleteTopicsRequest$Builder.class org.apache.kafka.common.requests.ApiVersionsRequest$Builder.class org.apache.kafka.common.requests.AddPartitionsToTxnRequest$Builder.class org.apache.kafka.common.requests.FindCoordinatorRequest$CoordinatorType.class org.apache.kafka.common.requests.AlterPartitionReassignmentsRequest$1.class org.apache.kafka.common.requests.DeleteRecordsResponse$PartitionResponse.class org.apache.kafka.common.requests.StopReplicaRequest$1.class org.apache.kafka.common.requests.ControlledShutdownResponse.class org.apache.kafka.common.requests.DescribeAclsResponse.class org.apache.kafka.common.requests.DescribeLogDirsRequest$Builder.class org.apache.kafka.common.requests.DescribeLogDirsResponse$LogDirInfo.class org.apache.kafka.common.requests.LeaveGroupRequest.class org.apache.kafka.common.requests.CreateDelegationTokenRequest$1.class org.apache.kafka.common.requests.StopReplicaRequest$Builder.class org.apache.kafka.common.requests.ListOffsetRequest$Builder.class org.apache.kafka.common.requests.DescribeGroupsRequest.class org.apache.kafka.common.requests.ProduceResponse$PartitionResponse.class org.apache.kafka.common.requests.FetchResponse$AbortedTransaction.class #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	zstd-jni-1.4.4-7.jar /com.github.luben/zstd-jni/1.4.4-7 查看zstd-jni所有版本文件 lz4-java-1.7.1.jar /org.lz4/lz4-java/1.7.1 查看lz4-java所有版本文件 snappy-java-1.1.7.3.jar /org.xerial.snappy/snappy-java/1.1.7.3 查看snappy-java所有版本文件 slf4j-api-1.7.30.jar /org.slf4j/slf4j-api/1.7.30 查看slf4j-api所有版本文件 jackson-databind-2.10.2.jar /com.fasterxml.jackson.core/jackson-databind/2.10.2 查看jackson-databind所有版本文件 jackson-datatype-jdk8-2.10.2.jar /com.fasterxml.jackson.datatype/jackson-datatype-jdk8/2.10.2 查看jackson-datatype-jdk8所有版本文件 bcpkix-jdk15on-1.64.jar /org.bouncycastle/bcpkix-jdk15on/1.64 查看bcpkix-jdk15on所有版本文件 junit-4.13.jar /junit/junit/4.13 查看junit所有版本文件 mockito-core-3.2.4.jar /org.mockito/mockito-core/3.2.4 查看mockito-core所有版本文件 jackson-jaxrs-json-provider-2.10.2.jar /com.fasterxml.jackson.jaxrs/jackson-jaxrs-json-provider/2.10.2 查看jackson-jaxrs-json-provider所有版本文件 slf4j-log4j12-1.7.30.jar /org.slf4j/slf4j-log4j12/1.7.30 查看slf4j-log4j12所有版本文件