Versions in this module Expand all Collapse all v0 v0.0.2 Dec 9, 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) Prepare(apiVersion int16) + type RequestPartition struct + Partition int32 + RecordSet protocol.RecordSet + type RequestTopic struct + Partitions []RequestPartition + Topic string + type Response struct + ThrottleTimeMs int32 + Topics []ResponseTopic + func (r *Response) ApiKey() protocol.ApiKey + type ResponseError struct + BatchIndex int32 + BatchIndexErrorMessage string + type ResponsePartition struct + BaseOffset int64 + ErrorCode int16 + ErrorMessage string + LogAppendTime int64 + LogStartOffset int64 + Partition int32 + RecordErrors []ResponseError + type ResponseTopic struct + Partitions []ResponsePartition + Topic string
Go to main page