Skip to main content

Module fetch

Module fetch 

Source

Structs§

AbortedTransactionV4
AbortedTransactionV12
FetchForgottenTopicV11
FetchForgottenTopicV12
FetchForgottenTopicV13
FetchNodeEndpointV16
A current-leader endpoint advertised by Fetch response v16 and newer.
FetchPartitionResponseV2
FetchPartitionResponseV4
FetchPartitionResponseV11
FetchPartitionResponseV12
FetchPartitionV2
FetchPartitionV11
FetchPartitionV12
FetchPartitionV17
FetchPartitionV18
FetchReplicaStateV15
Replica state carried by Fetch request versions 15 and newer.
FetchRequestV2
FetchRequestV4
FetchRequestV11
Fetch request version 11 with rack-aware read selection.
FetchRequestV12
Fetch request version 12 with flexible encoding and rack-aware read selection.
FetchRequestV13
Fetch request version 13 with topic UUIDs (KIP-516).
FetchRequestV14
Fetch request version 14. The v14 request wire shape is identical to v13; Kafka 4.x adds a tiered-storage error to the response contract.
FetchRequestV15
Fetch request version 15 with the KIP-903 replica state.
FetchRequestV16
Fetch request version 16. Kafka 4.3 keeps the v15 request shape.
FetchRequestV17
Fetch request version 17 adds the optional follower directory ID.
FetchRequestV18
Fetch request version 18 adds the follower high-watermark tagged field.
FetchResponseV2
FetchResponseV4
FetchResponseV11
Fetch response version 11 with broker-selected read replicas.
FetchResponseV12
Fetch response version 12 with flexible encoding and broker-selected reads.
FetchResponseV13
Fetch response version 13 with topic UUIDs (KIP-516).
FetchResponseV16
Fetch response version 16, including KIP-951 node endpoints.
FetchTopicResponseV2
FetchTopicResponseV4
FetchTopicResponseV11
FetchTopicResponseV12
FetchTopicResponseV13
FetchTopicV2
FetchTopicV11
FetchTopicV12
FetchTopicV13
FetchTopicV17
FetchTopicV18
MessageSetRecord

Constants§

API_KEY

Functions§

decode_message_set
Decodes Kafka MessageSet or RecordBatch bytes returned by a fetch-family response.

Type Aliases§

FetchForgottenTopicV14
FetchForgottenTopicV15
FetchForgottenTopicV16
FetchForgottenTopicV17
FetchForgottenTopicV18
FetchPartitionResponseV13
FetchPartitionResponseV14
FetchPartitionResponseV15
FetchPartitionResponseV16
FetchPartitionResponseV17
FetchPartitionResponseV18
FetchPartitionV13
FetchPartitionV14
FetchPartitionV15
FetchPartitionV16
FetchResponseV14
FetchResponseV15
FetchResponseV17
FetchResponseV18
FetchTopicResponseV14
FetchTopicResponseV15
FetchTopicResponseV16
FetchTopicResponseV17
FetchTopicResponseV18
FetchTopicV14
FetchTopicV15
FetchTopicV16