Simplify the Kafka consumer test

* previous version failed