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

Method GetMemberAssignment

sync_group_response.go:26–30  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

24}
25
26func (r *SyncGroupResponse) GetMemberAssignment() (*ConsumerGroupMemberAssignment, error) {
27 assignment := new(ConsumerGroupMemberAssignment)
28 err := decode(r.MemberAssignment, assignment, nil)
29 return assignment, err
30}
31
32func (r *SyncGroupResponse) encode(pe packetEncoder) error {
33 if r.Version >= 1 {

Callers 1

joinSyncMethod · 0.45

Calls 1

decodeFunction · 0.85

Tested by

no test coverage detected