rawproduce

type Error struct {
	Err error
}

type Request struct {
	TransactionalID string         `kafka:"min=v3,max=v8,nullable"`
	Acks            int16          `kafka:"min=v0,max=v8"`
	Timeout         int32          `kafka:"min=v0,max=v8"`
	Topics          []RequestTopic `kafka:"min=v0,max=v8"`
}

type RequestPartition struct {
	Partition int32                 `kafka:"min=v0,max=v8"`
	RecordSet protocol.RawRecordSet `kafka:"min=v0,max=v8"`
}

type RequestTopic struct {
	Topic      string             `kafka:"min=v0,max=v8"`
	Partitions []RequestPartition `kafka:"min=v0,max=v8"`
}