Currently, the CDC events are presented to the user via a particular channel, and a custom script has to pull those events, and then send them on to kafka (if using the kafka integration).
It would be ideal if maxscale could directly send these events directly to kafka. Necessary information would be the kafka cluster address, the zookeeper address(es), and what tables (via regex, ideally both white and black lists) that should be sent.
In theory, this could happen on the fly, and completely skip writing these events to disk.
It would be nice if maxscale could use zookeeper to keep the current position of the last event sent, in order to not send duplicates after a crash.