Kafka wire protocol packet diagrams

One page per Kafka API, generated from the message schemas on apache/kafka branch 4.0. Each page encodes a minimal example of the request and the response at the highest valid version and draws it as an RFC-style byte grid, an expanded object tree and the raw schema.84 APIs.

Records

0Produce(v12)1Fetch(v17)2ListOffsets(v10)

Consumer groups

8OffsetCommit(v9)9OffsetFetch(v9)10FindCoordinator(v6)11JoinGroup(v9)12Heartbeat(v4)13LeaveGroup(v5)14SyncGroup(v5)15DescribeGroups(v6)16ListGroups(v5)42DeleteGroups(v2)47OffsetDelete(v0)68ConsumerGroupHeartbeat(v1)69ConsumerGroupDescribe(v1)

Share groups

76ShareGroupHeartbeat(v0)77ShareGroupDescribe(v0)78ShareFetch(v0)79ShareAcknowledge(v0)83InitializeShareGroupState(v0)84ReadShareGroupState(v0)85WriteShareGroupState(v0)86DeleteShareGroupState(v0)87ReadShareGroupStateSummary(v0)

Transactions

22InitProducerId(v5)24AddPartitionsToTxn(v5)25AddOffsetsToTxn(v4)26EndTxn(v5)27WriteTxnMarkers(v1)28TxnOffsetCommit(v5)61DescribeProducers(v0)65DescribeTransactions(v0)66ListTransactions(v1)67AllocateProducerIds(v0)

Topics and partitions

3Metadata(v13)19CreateTopics(v7)20DeleteTopics(v6)21DeleteRecords(v2)23OffsetForLeaderEpoch(v4)34AlterReplicaLogDirs(v2)35DescribeLogDirs(v4)37CreatePartitions(v3)43ElectLeaders(v2)45AlterPartitionReassignments(v0)46ListPartitionReassignments(v0)56AlterPartition(v3)73AssignReplicasToDirs(v0)75DescribeTopicPartitions(v0)

Security and ACLs

17SaslHandshake(v1)29DescribeAcls(v3)30CreateAcls(v3)31DeleteAcls(v3)36SaslAuthenticate(v2)38CreateDelegationToken(v3)39RenewDelegationToken(v2)40ExpireDelegationToken(v2)41DescribeDelegationToken(v3)50DescribeUserScramCredentials(v0)51AlterUserScramCredentials(v0)

Configuration and quotas

32DescribeConfigs(v4)33AlterConfigs(v2)44IncrementalAlterConfigs(v1)48DescribeClientQuotas(v1)49AlterClientQuotas(v1)

Cluster and KRaft

18ApiVersions(v4)52Vote(v2)53BeginQuorumEpoch(v1)54EndQuorumEpoch(v1)55DescribeQuorum(v2)57UpdateFeatures(v2)58Envelope(v0)59FetchSnapshot(v1)60DescribeCluster(v2)62BrokerRegistration(v4)63BrokerHeartbeat(v1)64UnregisterBroker(v0)70ControllerRegistration(v0)71GetTelemetrySubscriptions(v0)72PushTelemetry(v0)74ListClientMetricsResources(v0)80AddRaftVoter(v0)81RemoveRaftVoter(v0)82UpdateRaftVoter(v0)