Переглянути джерело

Merge pull request #756 from pcallewaert/feat-describegroups

add missing metadata and assignment methods in describegroups
Evan Huus 9 роки тому
батько
коміт
1548006a8b
1 змінених файлів з 12 додано та 0 видалено
  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 (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
+}