(wb *writeBuffer)
| 288 | } |
| 289 | |
| 290 | func (t createTopicsRequest) writeTo(wb *writeBuffer) { |
| 291 | wb.writeArray(len(t.Topics), func(i int) { t.Topics[i].writeTo(wb) }) |
| 292 | wb.writeInt32(t.Timeout) |
| 293 | if t.v >= v1 { |
| 294 | wb.writeBool(t.ValidateOnly) |
| 295 | } |
| 296 | } |
| 297 | |
| 298 | type createTopicsResponseTopicError struct { |
| 299 | v apiVersion |
nothing calls this directly
no test coverage detected