Add comment on protocol details

numidiasoft · Dec 9, 2020 · 1d9a9a4 · 1d9a9a4
1 parent fed2c53
commit 1d9a9a4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/describegroups.go b/describegroups.go
@@ -300,6 +300,9 @@ func (t *describeGroupsResponseV0) readFrom(r *bufio.Reader, sz int) (remain int
 
 // decodeMemberAssignments converts raw assignment bytes to a DescribeGroupsResponseAssignments
 // struct.
+//
+// See https://github.com/apache/kafka/blob/2.4/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java#L49
+// for protocol details.
 func decodeMemberAssignments(rawAssignments []byte) (DescribeGroupsResponseAssignments, error) {
 	ma := DescribeGroupsResponseAssignments{}