Event-Driven Architecture

Понимает концепцию событийно-ориентированной архитектуры в контексте Java/Spring экосистемы. Знает назначение Spring Events, ApplicationEventPublisher, отличие синхронных и асинхронных событий в Spring Framework.

Понимает event loop в Node.js как основу event-driven модели. Знает EventEmitter, различает внутренние события приложения и внешние через message brokers. Понимает, зачем используют Redis Pub/Sub и BullMQ в Node.js-проектах.

Понимает концепцию событийно-ориентированной архитектуры и ограничения PHP как request-response языка. Знает Laravel Events/Listeners, Symfony EventDispatcher, понимает зачем PHP-приложениям нужны очереди (Laravel Queue, Symfony Messenger).

Понимает концепцию событийно-ориентированной архитектуры и отличие от синхронного request-response. Знает, что такое event bus и зачем нужен pub/sub паттерн в контексте Python-приложений.

Понимает концепцию event-driven архитектуры и роль Rust ownership model для безопасной обработки событий. Знает tokio channels, различает mpsc и broadcast каналы, понимает зачем Rust-сервисам нужны message brokers.

Понимает event-driven архитектуру в контексте Scala/Akka экосистемы. Знает Actor Model, Akka actors как способ обработки сообщений, различает tell и ask паттерны. Понимает назначение Kafka в Scala-проектах.

Разрабатывает event-driven Java-сервисы с использованием Spring Kafka, Spring AMQP или Spring Cloud Stream. Реализует producer/consumer с обработкой ошибок, настраивает retry-template, dead letter topic. Применяет @KafkaListener с ручным коммитом офсетов.

Реализует event-driven Node.js-сервисы с BullMQ, RabbitMQ (amqplib) или kafkajs. Обрабатывает события асинхронно с retry-логикой, настраивает dead letter queues. Использует NestJS CQRS-модуль или собственные реализации паттерна pub/sub.

Реализует event-driven обработку в PHP через Laravel Queue / Symfony Messenger с RabbitMQ или Redis. Настраивает workers, retry-политики, dead letter queues. Применяет domain events для декаплинга бизнес-логики в Laravel/Symfony приложениях.

Проектирует асинхронные обработчики событий на Python с использованием Celery, RabbitMQ или Redis Streams. Реализует паттерн producer-consumer, обрабатывает ошибки в цепочках событий и настраивает retry-политики.

Реализует event-driven Rust-сервисы с rdkafka, lapin (RabbitMQ) или async-nats. Использует tokio для async обработки событий, реализует graceful shutdown с CancellationToken. Обрабатывает ошибки десериализации событий через serde с proper error types.

Разрабатывает event-driven Scala-сервисы с Akka Streams, Alpakka Kafka или FS2/Cats Effect. Реализует reactive streams с backpressure, обрабатывает события через Akka Persistence для event sourcing. Применяет Scala type system для типобезопасных event contracts.

Проектирует event sourcing и CQRS на Java с использованием Axon Framework или собственных решений на Spring. Реализует saga-паттерн для распределённых транзакций, transactional outbox через Debezium CDC. Обеспечивает ordering гарантии и exactly-once обработку в Kafka Streams.

Проектирует event sourcing и CQRS на Node.js с учётом однопоточной модели. Реализует saga-оркестрацию через message broker, применяет transactional outbox. Обеспечивает идемпотентность обработчиков, управляет backpressure в event streams при высокой нагрузке.

Проектирует event-driven PHP-системы с Symfony Messenger или Laravel Horizon. Реализует event sourcing через Prooph или Ecotone framework, saga-паттерн для распределённых транзакций. Обеспечивает reliable message processing в условиях stateless PHP (long-running workers, Swoole/RoadRunner).

Проектирует event-driven системы на Python с гарантиями доставки (at-least-once, exactly-once). Применяет event sourcing для критичных доменов, реализует saga-паттерн для распределённых транзакций через Celery/Kafka. Обеспечивает идемпотентность обработчиков.

Проектирует высокопроизводительные event-driven системы на Rust, используя zero-copy десериализацию, lock-free очереди. Реализует event sourcing с типобезопасными агрегатами через Rust enum/trait system. Обеспечивает exactly-once обработку, transactional outbox с sqlx.

Проектирует event sourcing и CQRS на Scala с Akka Persistence / Akka Projection или чистыми FP-подходами (FS2 + Doobie). Реализует saga через Akka FSM, обеспечивает exactly-once через Kafka Streams DSL на Scala. Применяет ADT (sealed traits) для типобезопасных доменных событий.

Определяет архитектуру событийных Java-систем компании: выбор между Kafka, RabbitMQ, Pulsar, стратегия партиционирования, schema registry (Confluent/Apicurio). Разрабатывает корпоративные starter-ы для стандартизации работы с событиями в Spring Boot микросервисах.

Определяет архитектуру событийных Node.js-систем: выбор между BullMQ, Kafka, NATS. Проектирует schema validation для событий (JSON Schema, Avro), мониторинг consumer lag. Создаёт internal NPM-пакеты для стандартизации работы с событиями в Node.js-микросервисах команды.

Определяет архитектуру событийных PHP-систем: выбор между Symfony Messenger, Laravel Queue, Ecotone. Проектирует интеграцию PHP-сервисов с Kafka/RabbitMQ, schema validation для событий. Решает специфичные для PHP проблемы: memory leaks в long-running workers, перезапуск при деплое.

Определяет архитектуру событийных систем на уровне компании: выбор между Kafka, RabbitMQ, Redis Streams для Python-сервисов. Проектирует schema registry для событий, версионирование контрактов, мониторинг event flow. Обучает команду работе с eventually consistent системами.

Определяет архитектуру событийных Rust-систем: выбор транспорта, проектирование type-safe event schemas через Rust macros и proc macros. Разрабатывает internal crates для стандартизации event handling, обеспечивает compile-time гарантии корректности обработки событий.

Определяет архитектуру событийных Scala-систем: выбор между Akka/Pekko, ZIO, Cats Effect экосистемами для event processing. Проектирует schema evolution для Avro/Protobuf событий, мониторинг actor systems. Разрабатывает библиотеки для стандартизации event-driven коммуникации.

Формирует event-driven стратегию для Java-платформы масштаба enterprise. Определяет governance для событий, версионирование схем, миграционные стратегии. Руководит переходом от монолитного Spring-приложения к event-driven микросервисам, проектирует event mesh для мультикластерных инсталляций.

Формирует стратегию event-driven архитектуры для Node.js-платформы. Решает вопросы масштабирования event consumers с учётом особенностей Node.js (single-threaded), определяет стандарты CloudEvents, проектирует event catalog и governance. Руководит миграцией с монолитного Express/NestJS на event-driven микросервисы.

Формирует стратегию event-driven архитектуры для PHP-платформы. Определяет подходы к масштабированию PHP workers (Kubernetes + Horizon/Supervisor), стандарты событий, governance. Руководит миграцией монолитного Laravel/Symfony на event-driven микросервисы с учётом специфики PHP-экосистемы.

Формирует стратегию event-driven архитектуры для всей платформы. Определяет стандарты CloudEvents, governance для событийных схем, миграцию от монолитных Python-приложений к event-driven микросервисам. Проводит архитектурные ревью событийных систем и выстраивает observability для event flows.

Формирует стратегию event-driven архитектуры для Rust-платформы. Определяет баланс между compile-time safety и runtime flexibility для event schemas. Проектирует event mesh с учётом Rust-специфики (ownership, lifetimes в async контексте), руководит миграцией критичных сервисов на event-driven Rust.

Формирует event-driven стратегию для Scala-платформы: FP-first подход (ZIO/CE) vs Actor Model (Akka/Pekko), стандарты событий, governance. Проектирует migration path при смене фреймворков, обеспечивает observability для actor systems и stream processing. Руководит архитектурными решениями для reactive event-driven систем.