| 76 | } |
| 77 | |
| 78 | type Response struct { |
| 79 | ThrottleTimeMs int32 `kafka:"min=v1,max=v11"` |
| 80 | ErrorCode int16 `kafka:"min=v7,max=v11"` |
| 81 | SessionID int32 `kafka:"min=v7,max=v11"` |
| 82 | Topics []ResponseTopic `kafka:"min=v0,max=v11"` |
| 83 | } |
| 84 | |
| 85 | func (r *Response) ApiKey() protocol.ApiKey { return protocol.Fetch } |
| 86 |
nothing calls this directly
no outgoing calls
no test coverage detected