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

Method Prepare

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

Prepares the message before being sent to a kafka broker using the API version passed as argument.

(apiVersion int16)

Source from the content-addressed store, hash-verified

506 // Prepares the message before being sent to a kafka broker using the API
507 // version passed as argument.
508 Prepare(apiVersion int16)
509}
510
511// Splitter is an interface implemented by messages that can be split into

Callers 1

RoundTripMethod · 0.65

Implementers 2

Requestprotocol/produce/produce.go
Requestprotocol/leavegroup/leavegroup.go

Calls

no outgoing calls

Tested by

no test coverage detected