Для Kafka/NATS/RabbitMQ — поднимай реальный брокер в testcontainers или используй in-memory fake. Публикуй событие, жди его потребления с таймаутом. Проверяй идемпотентность — отправь одно событие дважды. Тестируй ordering и error handling. Для простых случаев — channel как замена брокера.
Как тестировать event-driven систему?
Middle+
161 просмотровAFK Offer AI
Найди баг: for _, f := range files { defer f.Close() }