MCPcopy Create free account
hub / github.com/IBM/sarama / AddGroupProtocolMetadata

Method AddGroupProtocolMetadata

join_group_request.go:246–254  ·  view source on GitHub ↗
(name string, metadata *ConsumerGroupMemberMetadata)

Source from the content-addressed store, hash-verified

244}
245
246func (r *JoinGroupRequest) AddGroupProtocolMetadata(name string, metadata *ConsumerGroupMemberMetadata) error {
247 bin, err := encode(metadata, nil)
248 if err != nil {
249 return err
250 }
251
252 r.AddGroupProtocol(name, bin)
253 return nil
254}

Callers 1

joinGroupRequestMethod · 0.95

Calls 2

AddGroupProtocolMethod · 0.95
encodeFunction · 0.85

Tested by

no test coverage detected