Versions in this module Expand all Collapse all v0 v0.4.50 Mar 11, 2024 v0.4.49 Mar 11, 2024 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 + Acks int16 + Timeout int32 + Topics []RequestTopic + TransactionalID string + func (r *Request) ApiKey() protocol.ApiKey + func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error) + func (r *Request) HasResponse() bool + func (r *Request) TypeKey() protocol.OverrideTypeKey + type RequestPartition struct + Partition int32 + RecordSet protocol.RawRecordSet + type RequestTopic struct + Partitions []RequestPartition + Topic string
Go to main page