Skip to content

Commit 760b875

Browse files
Update comment
1 parent c1963b8 commit 760b875

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

describegroups.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -105,6 +105,9 @@ type GroupMemberTopic struct {
105105
Partitions []int
106106
}
107107

108+
// DescribeGroups calls the Kafka DescribeGroups API to get information about one or more
109+
// consumer groups. See https://kafka.apache.org/protocol#The_Messages_DescribeGroups for
110+
// more information.
108111
func (c *Client) DescribeGroups(
109112
ctx context.Context,
110113
req *DescribeGroupsRequest,
@@ -153,6 +156,7 @@ func (c *Client) DescribeGroups(
153156
return resp, nil
154157
}
155158

159+
// readFrom
156160
func (t *DescribeGroupsResponseMemberMetadataOwnedPartition) readFrom(r *bufio.Reader, size int) (remain int, err error) {
157161
if remain, err = readString(r, size, &t.Topic); err != nil {
158162
return

0 commit comments

Comments
 (0)