Implement or review asynchronous code and message/event producers and consumers (Reactor, async/await, coroutines; Kafka, RabbitMQ, SQS) with emphasis on non-blocking behavior, layer-specific idempotency, contract safety, and dead-letter semantics. Use whenever async pipelines, consumers, producers, retries, backpressure, schedulers, or reconciliation flows are touched.
