Как написать тест для Kafka (продюсер/консюмер)?