v7

Documentation

Index

• Constants
• type PartitionData
• type PartitionResponse
• type ProduceResponse
• type Request
  • func (r *Request) Version() int16
• type Response
  • func (r *Response) Version() int16
• type TopicData

Constants

const Version int16 = 7

Types

type PartitionData

type PartitionData struct {
	Index   int32
	Records []byte
}

type PartitionResponse

type PartitionResponse struct {
	Index          int32
	ErrCode        errors.KafkaError
	BaseOffset     int64
	LogAppendTime  time.Time
	LogStartOffset int64
}

type ProduceResponse

type ProduceResponse struct {
	Name               string
	PartitionResponses []PartitionResponse
}

type Request

type Request struct {
	TransactionalID *string
	ACKs            int16
	TimeoutDuration time.Duration
	TopicData       []TopicData
}

func (*Request) Version

func (r *Request) Version() int16

type Response

type Response struct {
	Responses        []ProduceResponse
	ThrottleDuration time.Duration
}

func (*Response) Version

func (r *Response) Version() int16

type TopicData

type TopicData struct {
	Name          string
	PartitionData []PartitionData
}