hub / github.com/segmentio/kafka-go / UserData

Method UserData

groupbalancer.go:34–34 · view source on GitHub ↗

UserData provides the GroupBalancer an opportunity to embed custom UserData into the metadata. Will be used by JoinGroup to begin the consumer group handshake. See https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-JoinGroupRequest

()

Source from the content-addressed store, hash-verified

32	//
33	// See https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-JoinGroupRequest
34	UserData() ([]byte, error)
35
36	// DefineMemberships returns which members will be consuming
37	// which topic partitions

Callers 1

makeJoinGroupRequestMethod · 0.65

Implementers 3

RangeGroupBalancergroupbalancer.go

RoundRobinGroupBalancergroupbalancer.go

RackAffinityGroupBalancergroupbalancer.go

Calls

no outgoing calls

Tested by

no test coverage detected