Feature/add middleware

The newer Kafka client is causing test to fail in Mon-API so reverted back to the older client.