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

Struct Request

protocol/createacls/createacls.go:9–15  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

7}
8
9type Request struct {
10 // We need at least one tagged field to indicate that v2+ uses "flexible"
11 // messages.
12 _ struct{} `kafka:"min=v2,max=v3,tag"`
13
14 Creations []RequestACLs `kafka:"min=v0,max=v3"`
15}
16
17func (r *Request) ApiKey() protocol.ApiKey { return protocol.CreateAcls }
18

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected