| 82 | } |
| 83 | |
| 84 | type OffsetFetchResponse struct { |
| 85 | Version int16 |
| 86 | ThrottleTimeMs int32 |
| 87 | Blocks map[string]map[int32]*OffsetFetchResponseBlock // v0-7; on v8+ see Groups |
| 88 | Err KError // v0-7; on v8+ see Groups[i].Err |
| 89 | Groups []OffsetFetchResponseGroup // v8+ |
| 90 | } |
| 91 | |
| 92 | func (r *OffsetFetchResponse) setVersion(v int16) { |
| 93 | r.Version = v |
nothing calls this directly
no outgoing calls
no test coverage detected