Skip to content

Commit

Permalink
Merge pull request #756 from pcallewaert/feat-describegroups
Browse files Browse the repository at this point in the history
add missing metadata and assignment methods in describegroups
  • Loading branch information
eapache authored Oct 18, 2016
2 parents 376a293 + a7508ea commit 1548006
Showing 1 changed file with 12 additions and 0 deletions.
12 changes: 12 additions & 0 deletions describe_groups_response.go
Original file line number Diff line number Diff line change
Expand Up @@ -172,3 +172,15 @@ func (gmd *GroupMemberDescription) decode(pd packetDecoder) (err error) {

return nil
}

func (gmd *GroupMemberDescription) GetMemberAssignment() (*ConsumerGroupMemberAssignment, error) {
assignment := new(ConsumerGroupMemberAssignment)
err := decode(gmd.MemberAssignment, assignment)
return assignment, err
}

func (gmd *GroupMemberDescription) GetMemberMetadata() (*ConsumerGroupMemberMetadata, error) {
metadata := new(ConsumerGroupMemberMetadata)
err := decode(gmd.MemberMetadata, metadata)
return metadata, err
}

0 comments on commit 1548006

Please sign in to comment.