Browse Source

add missing metadata and assignment methods in describegroups

Pieter Callewaert 8 years ago
parent
commit
1ceccb326a
1 changed files with 12 additions and 0 deletions
  1. 12 0
      describe_groups_response.go

+ 12 - 0
describe_groups_response.go

@@ -172,3 +172,15 @@ func (gmd *GroupMemberDescription) decode(pd packetDecoder) (err error) {
 
 	return nil
 }
+
+func (r *GroupMemberDescription) GetMemberAssignment() (*ConsumerGroupMemberAssignment, error) {
+	assignment := new(ConsumerGroupMemberAssignment)
+	err := decode(r.MemberAssignment, assignment)
+	return assignment, err
+}
+
+func (r *GroupMemberDescription) GetMemberMetadata() (*ConsumerGroupMemberMetadata, error) {
+	assignment := new(ConsumerGroupMemberMetadata)
+	err := decode(r.MemberMetadata, assignment)
+	return assignment, err
+}