This is usually non-trivial and something people struggle to work with. The objective is to provide idiomatic integration testing framework for Kafka