Как тестировать event-driven систему?

Для Kafka/NATS/RabbitMQ — поднимай реальный брокер в testcontainers или используй in-memory fake. Публикуй событие, жди его потребления с таймаутом. Проверяй идемпотентность — отправь одно событие дважды. Тестируй ordering и error handling. Для простых случаев — channel как замена брокера.