Create API for producing messages

[lcobucci]

The approach here should be the simplest possible, we basically need to batch messages and send them on a specific interval (sending them to the correct partition leaders).

This also means that we won't provide transaction control on this first iteration.