Prepares the message before being sent to a kafka broker using the API version passed as argument.
(apiVersion int16)
| 506 | // Prepares the message before being sent to a kafka broker using the API |
| 507 | // version passed as argument. |
| 508 | Prepare(apiVersion int16) |
| 509 | } |
| 510 | |
| 511 | // Splitter is an interface implemented by messages that can be split into |