group describe: use new kmsg types

twmb · Nov 5, 2021 · 4b22ef9 · 4b22ef9
1 parent 387ff5d
commit 4b22ef9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/commands/admin/group/describe.go b/commands/admin/group/describe.go
@@ -406,8 +406,8 @@ type describedGroupMember struct {
 	InstanceID       *string
 	ClientID         string
 	ClientHost       string
-	MemberMetadata   kmsg.GroupMemberMetadata
-	MemberAssignment kmsg.GroupMemberAssignment
+	MemberMetadata   kmsg.ConsumerMemberMetadata
+	MemberAssignment kmsg.ConsumerMemberAssignment
 }
 
 type describedGroup struct {

diff --git a/commands/consume/consumer_offsets.go b/commands/consume/consumer_offsets.go
@@ -255,7 +255,7 @@ func (co *consumeOutput) formatGroupMetadata(dst []byte, r *kgo.Record) ([]byte,
 				continue
 			}
 
-			var m kmsg.GroupMemberMetadata
+			var m kmsg.ConsumerMemberMetadata
 			if err := m.ReadFrom(member.Subscription); err != nil {
 				fmt.Fprintf(tw, "\t\tSubscription\t(could not decode %d bytes)\n", len(member.Subscription))
 			} else {
@@ -290,7 +290,7 @@ func (co *consumeOutput) formatGroupMetadata(dst []byte, r *kgo.Record) ([]byte,
 					fmt.Fprintf(tw, "\t\t      OwnedPartitions\t%s\n", sb.String())
 				}
 			}
-			var a kmsg.GroupMemberAssignment
+			var a kmsg.ConsumerMemberAssignment
 			if err := a.ReadFrom(member.Assignment); err != nil {
 				fmt.Fprintf(tw, "\t\tAssignment\t(could not decode %d bytes)\n", len(member.Assignment))
 			} else {