Add withKafkaConsumer / withKafkaProducer, single message test