Blog post about Testing kafka based applications Different approaches how to make Unit, integration and end-to-end tests.
—- https://github.com/sysco-middleware/kafka-testing

Proof of concept: jmx-exporter and kafka clients. Main idea: expose JMX metrics of applications which use Apache Kafka APIs. Jmx exporter requires config patterns.