Kafka3.5.0源代码压缩包_kafka源码下载资源-CSDN文库

kafka

102 浏览量 2023-07-19 21:39:55 上传评论收藏 10.52MB TGZ 举报

共2000个文件

java：3973个

scala：636个

json：200个

资源推荐

资源详情

资源评论

收起资源包目录

Kafka 3.5.0 源代码压缩包（2000个子文件）

dsl-api.html 320KB

ops.html 216KB

upgrade.html 197KB

security.html 168KB

upgrade-guide.html 107KB

config-streams.html 89KB

connect.html 78KB

design.html 74KB

processor-api.html 60KB

interactive-queries.html 41KB

core-concepts.html 31KB

tutorial.html 31KB

implementation.html 25KB

memory-mgmt.html 25KB

index.html 23KB

protocol.html 22KB

testing.html 20KB

configuration.html 19KB

quickstart.html 19KB

running-app.html 18KB

quickstart.html 18KB

datatypes.html 17KB

write-streams.html 16KB

dsl-topology-naming.html 15KB

security.html 15KB

app-reset-tool.html 14KB

architecture.html 14KB

introduction.html 13KB

toc.html 13KB

manage-topics.html 9KB

api.html 6KB

documentation.html 6KB

uses.html 6KB

index.html 5KB

migration.html 2KB

package.html 2KB

package.html 1KB

ecosystem.html 1KB

dsl-topology-naming.html 924B

interactive-queries.html 924B

app-reset-tool.html 919B

config-streams.html 919B

manage-topics.html 918B

processor-api.html 918B

write-streams.html 918B

running-app.html 916B

memory-mgmt.html 916B

datatypes.html 914B

security.html 913B

dsl-api.html 912B

testing.html 912B

index.html 910B

core-concepts.html 899B

upgrade-guide.html 899B

architecture.html 898B

quickstart.html 896B

tutorial.html 894B

index.html 891B

package.html 830B

index.html 824B

KafkaAdminClientTest.java 357KB

KStream.java 312KB

TaskManagerTest.java 236KB

KafkaAdminClient.java 229KB

DistributedHerderTest.java 195KB

ConsumerCoordinatorTest.java 194KB

RequestResponseTest.java 183KB

TransactionManagerTest.java 175KB

FetcherTest.java 164KB

KStreamImplTest.java 163KB

SenderTest.java 158KB

KafkaConsumer.java 148KB

StreamThreadTest.java 140KB

KafkaConsumerTest.java 140KB

KTable.java 136KB

DistributedHerder.java 136KB

ReplicationControlManagerTest.java 135KB

SaslAuthenticatorTest.java 132KB

KafkaRaftClientTest.java 120KB

KStreamKStreamJoinTest.java 116KB

StreamTaskTest.java 116KB

StreamsPartitionAssignorTest.java 115KB

TopologyTest.java 112KB

WorkerTest.java 110KB

KafkaProducerTest.java 110KB

KafkaRaftClient.java 107KB

QuorumController.java 100KB

KafkaStreams.java 97KB

InternalTopicManagerTest.java 97KB

ReplicationControlManager.java 96KB

Worker.java 96KB

InternalTopologyBuilder.java 94KB

StreamsConfig.java 94KB

WorkerSinkTaskTest.java 94KB

ProcessorTopologyTest.java 94KB

KStreamSlidingWindowAggregateTest.java 93KB

KafkaConfigBackingStoreTest.java 92KB

MessageDataGenerator.java 88KB

KafkaProducer.java 87KB

TaskManager.java 85KB

共 2000 条

/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.kafka.clients.admin; import org.apache.kafka.clients.ClientDnsLookup; import org.apache.kafka.clients.ClientRequest; import org.apache.kafka.clients.ClientUtils; import org.apache.kafka.clients.MockClient; import org.apache.kafka.clients.NodeApiVersions; import org.apache.kafka.clients.admin.DeleteAclsResult.FilterResults; import org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo; import org.apache.kafka.clients.consumer.ConsumerPartitionAssignor; import org.apache.kafka.clients.consumer.OffsetAndMetadata; import org.apache.kafka.clients.consumer.internals.ConsumerProtocol; import org.apache.kafka.common.Cluster; import org.apache.kafka.common.ConsumerGroupState; import org.apache.kafka.common.ElectionType; import org.apache.kafka.common.KafkaException; import org.apache.kafka.common.KafkaFuture; import org.apache.kafka.common.Node; import org.apache.kafka.common.TopicCollection; import org.apache.kafka.common.PartitionInfo; import org.apache.kafka.common.TopicPartition; import org.apache.kafka.common.TopicPartitionReplica; import org.apache.kafka.common.Uuid; import org.apache.kafka.common.acl.AccessControlEntry; import org.apache.kafka.common.acl.AccessControlEntryFilter; import org.apache.kafka.common.acl.AclBinding; import org.apache.kafka.common.acl.AclBindingFilter; import org.apache.kafka.common.acl.AclOperation; import org.apache.kafka.common.acl.AclPermissionType; import org.apache.kafka.common.config.ConfigException; import org.apache.kafka.common.config.ConfigResource; import org.apache.kafka.common.errors.ApiException; import org.apache.kafka.common.errors.AuthenticationException; import org.apache.kafka.common.errors.ClusterAuthorizationException; import org.apache.kafka.common.errors.FencedInstanceIdException; import org.apache.kafka.common.errors.GroupAuthorizationException; import org.apache.kafka.common.errors.GroupSubscribedToTopicException; import org.apache.kafka.common.errors.InvalidRequestException; import org.apache.kafka.common.errors.InvalidTopicException; import org.apache.kafka.common.errors.LeaderNotAvailableException; import org.apache.kafka.common.errors.LogDirNotFoundException; import org.apache.kafka.common.errors.NotLeaderOrFollowerException; import org.apache.kafka.common.errors.OffsetOutOfRangeException; import org.apache.kafka.common.errors.SaslAuthenticationException; import org.apache.kafka.common.errors.SecurityDisabledException; import org.apache.kafka.common.errors.ThrottlingQuotaExceededException; import org.apache.kafka.common.errors.TimeoutException; import org.apache.kafka.common.errors.TopicAuthorizationException; import org.apache.kafka.common.errors.TopicDeletionDisabledException; import org.apache.kafka.common.errors.TopicExistsException; import org.apache.kafka.common.errors.UnknownMemberIdException; import org.apache.kafka.common.errors.UnknownServerException; import org.apache.kafka.common.errors.UnknownTopicIdException; import org.apache.kafka.common.errors.UnknownTopicOrPartitionException; import org.apache.kafka.common.errors.UnsupportedVersionException; import org.apache.kafka.common.feature.Features; import org.apache.kafka.common.internals.Topic; import org.apache.kafka.common.message.AlterPartitionReassignmentsResponseData; import org.apache.kafka.common.message.AlterReplicaLogDirsResponseData; import org.apache.kafka.common.message.AlterReplicaLogDirsResponseData.AlterReplicaLogDirPartitionResult; import org.apache.kafka.common.message.AlterReplicaLogDirsResponseData.AlterReplicaLogDirTopicResult; import org.apache.kafka.common.message.AlterUserScramCredentialsResponseData; import org.apache.kafka.common.message.ApiMessageType; import org.apache.kafka.common.message.ApiVersionsResponseData; import org.apache.kafka.common.message.ApiVersionsResponseData.ApiVersion; import org.apache.kafka.common.message.CreateAclsResponseData; import org.apache.kafka.common.message.CreatePartitionsResponseData; import org.apache.kafka.common.message.CreatePartitionsResponseData.CreatePartitionsTopicResult; import org.apache.kafka.common.message.CreateTopicsResponseData; import org.apache.kafka.common.message.CreateTopicsResponseData.CreatableTopicResult; import org.apache.kafka.common.message.CreateTopicsResponseData.CreatableTopicResultCollection; import org.apache.kafka.common.message.DeleteAclsResponseData; import org.apache.kafka.common.message.DeleteGroupsResponseData; import org.apache.kafka.common.message.DeleteGroupsResponseData.DeletableGroupResult; import org.apache.kafka.common.message.DeleteGroupsResponseData.DeletableGroupResultCollection; import org.apache.kafka.common.message.DeleteRecordsResponseData; import org.apache.kafka.common.message.DeleteTopicsResponseData; import org.apache.kafka.common.message.DeleteTopicsResponseData.DeletableTopicResult; import org.apache.kafka.common.message.DeleteTopicsResponseData.DeletableTopicResultCollection; import org.apache.kafka.common.message.DescribeAclsResponseData; import org.apache.kafka.common.message.DescribeClusterResponseData; import org.apache.kafka.common.message.DescribeClusterResponseData.DescribeClusterBroker; import org.apache.kafka.common.message.DescribeConfigsResponseData; import org.apache.kafka.common.message.DescribeGroupsResponseData; import org.apache.kafka.common.message.DescribeGroupsResponseData.DescribedGroupMember; import org.apache.kafka.common.message.DescribeLogDirsResponseData; import org.apache.kafka.common.message.DescribeLogDirsResponseData.DescribeLogDirsTopic; import org.apache.kafka.common.message.DescribeProducersResponseData; import org.apache.kafka.common.message.DescribeQuorumResponseData; import org.apache.kafka.common.message.DescribeTransactionsResponseData; import org.apache.kafka.common.message.DescribeUserScramCredentialsResponseData; import org.apache.kafka.common.message.DescribeUserScramCredentialsResponseData.CredentialInfo; import org.apache.kafka.common.message.ElectLeadersResponseData.PartitionResult; import org.apache.kafka.common.message.ElectLeadersResponseData.ReplicaElectionResult; import org.apache.kafka.common.message.FindCoordinatorRequestData; import org.apache.kafka.common.message.FindCoordinatorResponseData; import org.apache.kafka.common.message.IncrementalAlterConfigsResponseData; import org.apache.kafka.common.message.IncrementalAlterConfigsResponseData.AlterConfigsResourceResponse; import org.apache.kafka.common.message.LeaveGroupRequestData; import org.apache.kafka.common.message.InitProducerIdResponseData; import org.apache.kafka.common.message.LeaveGroupRequestData.MemberIdentity; import org.apache.kafka.common.message.LeaveGroupResponseData; import org.apache.kafka.common.message.LeaveGroupResponseData.MemberResponse; import org.apache.kafka.common.message.ListGroupsResponseData; import org.apache.kafka.common.message.ListOffsetsResponseData; import org.apache.kafka.common.message.ListOffsetsResponseData.ListOffsetsTopicResponse; import org.apache.kafka.common.message.ListPartitionReassignmentsResponseData; import org.apache.kafka.common.message.ListTransactionsResponseData; import org.apache.kafka.common.message.MetadataResponseData; import org.apache.kafka.

评论收藏

内容反馈