Simple example taken from the API docs. This is a completely synchronous examples
Tried an async example which failed. There is an example in the most documentation but this is not really async.
Investigated the Kafka Stream code and found they use EventEvent to join Kafka to Most api. This is an example which demonstrates this.