MCPcopy
hub / github.com/segmentio/kafka-go / Request

Struct Request

protocol/rawproduce/rawproduce.go:16–21  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

14}
15
16type Request struct {
17 TransactionalID string `kafka:"min=v3,max=v8,nullable"`
18 Acks int16 `kafka:"min=v0,max=v8"`
19 Timeout int32 `kafka:"min=v0,max=v8"`
20 Topics []RequestTopic `kafka:"min=v0,max=v8"`
21}
22
23func (r *Request) ApiKey() protocol.ApiKey { return protocol.Produce }
24

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected