Versions in this module Expand all Collapse all v0 v0.4.28 Feb 4, 2023 Changes in this version + type Error struct + Err error + func NewError(err error) *Error + func (e *Error) Error() string + func (e *Error) Unwrap() error + type Request struct + ForgottenTopics []RequestForgottenTopic + IsolationLevel int8 + MaxBytes int32 + MaxWaitTime int32 + MinBytes int32 + RackID string + ReplicaID int32 + SessionEpoch int32 + SessionID int32 + Topics []RequestTopic + func (r *Request) ApiKey() protocol.ApiKey + func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error) + type RequestForgottenTopic struct + Partitions []int32 + Topic string + type RequestPartition struct + CurrentLeaderEpoch int32 + FetchOffset int64 + LogStartOffset int64 + Partition int32 + PartitionMaxBytes int32 + type RequestTopic struct + Partitions []RequestPartition + Topic string + type Response struct + ErrorCode int16 + SessionID int32 + ThrottleTimeMs int32 + Topics []ResponseTopic + func (r *Response) ApiKey() protocol.ApiKey + type ResponsePartition struct + AbortedTransactions []ResponseTransaction + ErrorCode int16 + HighWatermark int64 + LastStableOffset int64 + LogStartOffset int64 + Partition int32 + PreferredReadReplica int32 + RecordSet protocol.RecordSet + type ResponseTopic struct + Partitions []ResponsePartition + Topic string + type ResponseTransaction struct + FirstOffset int64 + ProducerID int64
Go to main page