(wb *writeBuffer)
| 204 | } |
| 205 | |
| 206 | func (t offsetCommitRequestV2) writeTo(wb *writeBuffer) { |
| 207 | wb.writeString(t.GroupID) |
| 208 | wb.writeInt32(t.GenerationID) |
| 209 | wb.writeString(t.MemberID) |
| 210 | wb.writeInt64(t.RetentionTime) |
| 211 | wb.writeArray(len(t.Topics), func(i int) { t.Topics[i].writeTo(wb) }) |
| 212 | } |
| 213 | |
| 214 | type offsetCommitResponseV2PartitionResponse struct { |
| 215 | Partition int32 |
nothing calls this directly
no test coverage detected