Builds a Kafka Producer and assoc it onto the message map

Creates an asynchronous Kafka Consumer of all topics defined in the
supplied `topic-metadata`

Puts all messages on the channel in the returned response. It is the
responsibility of the caller to arrange for the read the channel to
be read by some other process.

Must be closed with `close-consumer` when no longer required

Deliver the `ack` promise with the result of attempting to write to kafka. The
default command-handler waits for this before on to the next command so the
test response may indicate the success/failure of each write command.

Clojurize the ConsumerRecord returned from consuming a kafka record

Creates a kafka ProducerRecord for use with `send!`.

Returns a function that takes a consumer and puts any messages retrieved
by polling it onto the supplied `messages` channel

Creates an asynchronous kafka producer to be used by a test-machine for for
injecting test messages

Seeks to the end of all the partitions assigned to the given consumer
and returns the updated consumer

Subscribes to specified topics

`consumer` should be a kafka consumer
`topic-config` should be a sequence of topic-metadata maps

Subscribes to `topic-collection` and seeks to the end of all partitions. This
is usually what you want in a testing context. It's best for the test you're
trying to run now to ignore all the garbage created by previous tests.