Versions in this module Expand all Collapse all v0 v0.0.2 Dec 9, 2024 Changes in this version + type Request struct + IsolationLevel int8 + ReplicaID int32 + Topics []RequestTopic + func (r *Request) ApiKey() protocol.ApiKey + func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error) + func (r *Request) Split(cluster protocol.Cluster) ([]protocol.Message, protocol.Merger, error) + type RequestPartition struct + CurrentLeaderEpoch int32 + Partition int32 + Timestamp int64 + type RequestTopic struct + Partitions []RequestPartition + Topic string + type Response struct + ThrottleTimeMs int32 + Topics []ResponseTopic + func (r *Response) ApiKey() protocol.ApiKey + func (r *Response) Merge(requests []protocol.Message, results []interface{}) (protocol.Message, error) + type ResponsePartition struct + ErrorCode int16 + LeaderEpoch int32 + Offset int64 + Partition int32 + Timestamp int64 + type ResponseTopic struct + Partitions []ResponsePartition + Topic string
Go to main page