This file defines builders to assist in creating kafka payloads for unit testing. fetchResponseBuilder builds v10 fetch responses. The version of the v10 fetch responses are not as important as the message sets contained within, as this type is ultimately used to unit test the message set reader tha
| 16 | // type is ultimately used to unit test the message set reader that consumes the |
| 17 | // rest of the response once the header has been parsed. |
| 18 | type fetchResponseBuilder struct { |
| 19 | header fetchResponseHeader |
| 20 | msgSets []messageSetBuilder |
| 21 | rendered []byte |
| 22 | } |
| 23 | |
| 24 | type fetchResponseHeader struct { |
| 25 | throttle int32 |
nothing calls this directly
no outgoing calls
no test coverage detected