Как вы покрывали Kafka автотестами? Расскажи подробнее.