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

Method Required

protocol/protocol.go:471–471  ·  view source on GitHub ↗

Required should return true when a RawExchange is needed. The passed in versions are the negotiated versions for the connection performing the request.

(versions map[ApiKey]int16)

Source from the content-addressed store, hash-verified

469 // The passed in versions are the negotiated versions for the connection
470 // performing the request.
471 Required(versions map[ApiKey]int16) bool
472 // RawExchange is given the raw connection to the broker and the Message
473 // is responsible for writing itself to the connection as well as reading
474 // the response.

Callers 1

RoundTripMethod · 0.65

Implementers 1

Requestprotocol/saslauthenticate/saslauthenti

Calls

no outgoing calls

Tested by

no test coverage detected