(wb *writeBuffer)
| 171 | } |
| 172 | |
| 173 | func (t groupAssignment) writeTo(wb *writeBuffer) { |
| 174 | wb.writeInt16(t.Version) |
| 175 | wb.writeInt32(int32(len(t.Topics))) |
| 176 | |
| 177 | for topic, partitions := range t.Topics { |
| 178 | wb.writeString(topic) |
| 179 | wb.writeInt32Array(partitions) |
| 180 | } |
| 181 | |
| 182 | wb.writeBytes(t.UserData) |
| 183 | } |
| 184 | |
| 185 | func (t *groupAssignment) readFrom(r *bufio.Reader, size int) (remain int, err error) { |
| 186 | // I came across this case when testing for compatibility with bsm/sarama-cluster. It |