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

В автотестах Kafka проверяют контракт события и бизнес-эффект: отправку, обработку, ошибки, повторы и порядок в пределах нужной партиции, а не только наличие сообщения.

Для интеграционного теста поднимают изолированный брокер или выделенный тестовый контур, используют уникальный идентификатор события и ограниченное ожидание. Проверяют key, payload, headers и изменение в системе-потребителе. Отдельные сценарии — повторная доставка, некорректное сообщение, временный отказ и восстановление consumer. Тестовый consumer не должен случайно делить group с приложением и забирать его сообщения. Внешние зависимости подменяют, а временные topic и данные очищают.