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

Struct Request

protocol/produce/produce.go:13–18  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected