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

Method AddGroupAssignmentMember

sync_group_request.go:199–210  ·  view source on GitHub ↗
(
	memberId string,
	memberAssignment *ConsumerGroupMemberAssignment,
)

Source from the content-addressed store, hash-verified

197}
198
199func (r *SyncGroupRequest) AddGroupAssignmentMember(
200 memberId string,
201 memberAssignment *ConsumerGroupMemberAssignment,
202) error {
203 bin, err := encode(memberAssignment, nil)
204 if err != nil {
205 return err
206 }
207
208 r.AddGroupAssignment(memberId, bin)
209 return nil
210}

Callers 1

syncGroupRequestMethod · 0.95

Calls 2

AddGroupAssignmentMethod · 0.95
encodeFunction · 0.85

Tested by

no test coverage detected