Scala Kafka consumer test