Method Broker

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

Given a representation of the kafka cluster state as argument, returns the broker that the message should be routed to.

(Cluster)

Source from the content-addressed store, hash-verified

481	// Given a representation of the kafka cluster state as argument, returns
482	// the broker that the message should be routed to.
483	Broker(Cluster) (Broker, error)
484	}
485
486	// GroupMessage is an extension of the Message interface implemented by some

testConnBrokerFunction · 0.65

sendRequestMethod · 0.65

Connconn.go

Requestprotocol/fetch/fetch.go

Requestprotocol/createtopics/createtopics.go

Requestprotocol/deletetopics/deletetopics.go

Requestprotocol/createacls/createacls.go

Requestprotocol/listoffsets/listoffsets.go

Requestprotocol/electleaders/electleaders.go

Requestprotocol/produce/produce.go

Requestprotocol/alterconfigs/alterconfigs.go

Requestprotocol/incrementalalterconfigs/incre

Requestprotocol/describeconfigs/describeconfi

Requestprotocol/rawproduce/rawproduce.go

no outgoing calls

testConnBrokerFunction · 0.52