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