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

Method RawExchange

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

RawExchange is given the raw connection to the broker and the Message is responsible for writing itself to the connection as well as reading the response.

(rw io.ReadWriter)

Source from the content-addressed store, hash-verified

473 // is responsible for writing itself to the connection as well as reading
474 // the response.
475 RawExchange(rw io.ReadWriter) (Message, error)
476}
477
478// BrokerMessage is an extension of the Message interface implemented by some

Callers 1

RoundTripMethod · 0.65

Implementers 1

Requestprotocol/saslauthenticate/saslauthenti

Calls

no outgoing calls

Tested by

no test coverage detected