Initial working code.

Wrap kafka client so that it doesn't matter for citrus what kind of
event bus is used.