Produce

Documentation

Index

• func NewRequest(args *Args, recordSet []byte) *api.Request
• type Args
• type Data
• type PartitionResponse
• type Request
• type Response
  • func UnmarshalResponse(b []byte) (*Response, error)
• type TopicData
• type TopicResponse

Functions

func NewRequest

func NewRequest(args *Args, recordSet []byte) *api.Request

Types

type Args

type Args struct {
	ClientId  string
	Topic     string
	Partition int32
	Acks      int16 // 0: no, 1: leader only, -1: all ISRs (as specified by min.insync.replicas)
	TimeoutMs int32
}

type Data

type Data struct {
	Partition int32
	RecordSet []byte
}

type PartitionResponse

type PartitionResponse struct {
	Partition      int32
	ErrorCode      int16
	BaseOffset     int64
	LogAppendTime  int64
	LogStartOffset int64
}

type Request

type Request struct {
	TransactionalId string // NULLABLE_STRING
	Acks            int16  // 0: no, 1: leader only, -1: all ISRs (as specified by min.insync.replicas)
	TimeoutMs       int32
	TopicData       []TopicData
}

type Response

type Response struct {
	TopicResponses []TopicResponse
	ThrottleTimeMs int32
}

func UnmarshalResponse

func UnmarshalResponse(b []byte) (*Response, error)

type TopicData

type TopicData struct {
	Topic string
	Data  []Data
}

type TopicResponse

type TopicResponse struct {
	Topic              string
	PartitionResponses []PartitionResponse
}