Паттерны Message Brokers

Понимает паттерны брокеров сообщений в Java/Spring: pub-sub через Spring Cloud Stream, JMS templates и Kafka listeners. Следует командным конвенциям для публикации и потребления сообщений с автоконфигурацией Spring Boot.

Понимает паттерны брокеров сообщений в Node.js: pub-sub с BullMQ, event-driven messaging с amqplib. Следует командным конвенциям для асинхронной обработки сообщений через очереди и event emitters в Express/Fastify-сервисах.

Понимает паттерны брокеров сообщений в PHP: pub-sub через Symfony Messenger, queue workers через Laravel Queues. Следует командным конвенциям для диспатчинга и потребления сообщений через драйверы Redis, RabbitMQ или SQS.

Понимает базовые концепции message broker'ов: publish/subscribe, point-to-point, очереди сообщений. Умеет отправить и получить сообщение через RabbitMQ (pika) или Redis pub/sub. Знает зачем нужна асинхронная коммуникация между сервисами.

Понимает паттерны брокеров сообщений в Rust: pub-sub с lapin (AMQP), async consumers через tokio channels. Следует командным конвенциям для типобезопасной сериализации сообщений с serde и паттернов надёжной доставки.

Понимает паттерны брокеров сообщений в Scala: pub-sub через Akka Streams/ZIO Streams, интеграция Kafka через Alpakka. Следует командным конвенциям для функциональной обработки сообщений с effect systems и обработкой backpressure.

Работает с messaging в Java-экосистеме: использует Spring Kafka для Kafka-интеграции, Spring Cloud Stream для абстракции от брокера, настраивает consumer groups и partition assignment. Применяет @KafkaListener с concurrency для параллельной обработки и настраивает error handler с retry.

Работает с message broker'ами в Node.js: использует KafkaJS для Kafka-интеграции, настраивает NestJS microservices с RabbitMQ/Kafka транспортом, реализует pub/sub через Redis Streams. Применяет consumer groups и настраивает retry логику с exponential backoff.

Работает с messaging в PHP: использует Symfony Messenger с RabbitMQ/Redis транспортом, настраивает Laravel Horizon для мониторинга очередей, применяет routing по message type. Обрабатывает failed jobs через retry и dead letter queues, настраивает приоритетные очереди.

Работает с message broker'ами в Python-проектах: использует Celery с RabbitMQ/Redis для фоновых задач, реализует pub/sub через confluent-kafka или aiokafka, применяет паттерны competing consumers и fan-out. Настраивает dead letter queues для обработки ошибок.

Работает с message broker'ами в Rust: реализует consumer groups через rdkafka с offset management, использует NATS через async-nats для lightweight messaging, применяет tokio channels для internal message passing. Обрабатывает backpressure через bounded channels и flow control.

Работает с messaging в Scala-экосистеме: использует Alpakka Kafka с Akka Streams для reactive processing, настраивает consumer groups с committable sources, реализует at-least-once delivery через committing offsets. Применяет fs2-kafka для functional stream processing с cats-effect.

Проектирует messaging-архитектуру для Java-микросервисов: реализует transactional outbox через Spring @Transactional + Debezium, настраивает exactly-once processing в Kafka с transactional producer, проектирует schema evolution через Confluent Schema Registry. Оптимизирует consumer throughput через batch listener.

Проектирует messaging-архитектуру для Node.js сервисов: реализует transactional outbox с MongoDB change streams или PostgreSQL LISTEN/NOTIFY, настраивает Kafka с exactly-once semantics через idempotent producer. Проектирует event schema management и consumer idempotency через deduplication store.

Проектирует messaging-архитектуру для PHP-систем: реализует event-driven коммуникацию между PHP-сервисами через RabbitMQ с exchange routing, интегрирует PHP с Kafka через php-rdkafka для event streaming. Проектирует idempotent consumers и transactional outbox для consistency.

Проектирует messaging-архитектуру для Python-сервисов: выбирает между RabbitMQ, Kafka, Redis Streams для разных сценариев, реализует transactional outbox для гарантии доставки, настраивает exactly-once semantics в Kafka. Проектирует schema registry для эволюции форматов сообщений.

Проектирует высокопроизводительные messaging-системы на Rust: реализует zero-copy десериализацию для максимального throughput, проектирует custom message routing через tokio task scheduling, настраивает batch processing с configurable flush intervals. Оптимизирует memory allocation для sustained high-throughput processing.

Проектирует messaging-архитектуру для Scala: реализует exactly-once processing через Kafka transactions с Alpakka, проектирует event sourcing с Akka Persistence или EventStoreDB, настраивает stream processing с Flink/Kafka Streams через Scala API. Оптимизирует backpressure и parallelism.

Стандартизирует messaging в Java-экосистеме компании: выбирает между Spring Cloud Stream, Axon Framework, Eventuate для event-driven архитектуры, проектирует saga orchestration с Temporal или Axon Saga. Внедряет event store для audit и replay, определяет стратегию topic governance.

Стандартизирует messaging в Node.js экосистеме: создает internal SDK для абстракции от конкретного broker'а, проектирует event catalog с типизированными событиями через TypeScript, внедряет distributed tracing для message flows. Определяет паттерны для saga и choreography в Node.js.

Стандартизирует messaging в PHP-экосистеме: определяет паттерны для async коммуникации с учётом PHP process model ограничений, внедряет Ecotone Framework для CQRS/event sourcing, проектирует интеграцию PHP-монолита с event-driven микросервисами. Обучает команды messaging best practices.

Определяет messaging-стратегию для организации: стандартизирует паттерны (saga, choreography vs orchestration, event sourcing), внедряет monitoring/alerting для message lag и consumer health. Проектирует партицирование Kafka-топиков для оптимальной параллелизации и data locality.

Определяет messaging-архитектуру для Rust-системы: создает внутренний messaging framework с абстракцией над broker'ами, проектирует event sourcing с custom event store на Rust, стандартизирует serialization через Serde с schema evolution. Менторит по идиоматичной обработке сообщений в async Rust.

Стандартизирует messaging в Scala-экосистеме: выбирает между Alpakka, fs2-kafka и ZIO Kafka для разных команд, проектирует event-driven архитектуру с CQRS через Akka Projection, внедряет schema registry интеграцию с Avro/Protobuf для type-safe evolution.

Формирует enterprise messaging стратегию: проектирует multi-cluster Kafka платформу с cross-datacenter репликацией, определяет стандарты для event-driven архитектуры на уровне организации. Влияет на выбор между Kafka, Pulsar, RabbitMQ для разных use cases с учётом TCO и operational complexity.

Формирует event-driven стратегию для Node.js платформы: проектирует real-time event processing pipeline с Kafka Streams/ksqlDB, определяет паттерны для event sourcing с event store. Влияет на архитектуру streaming-платформы с учётом Node.js event loop модели и backpressure handling.

Формирует messaging стратегию для PHP-платформы: определяет как PHP-системы участвуют в enterprise event-driven архитектуре, проектирует подходы к async processing с учётом FPM/Swoole/RoadRunner runtime. Влияет на архитектурные решения по переходу от synchronous к event-driven в PHP legacy.

Формирует платформенную стратегию асинхронной коммуникации: проектирует multi-region messaging с Active-Active репликацией Kafka, определяет governance для schema evolution и topic naming conventions. Влияет на архитектуру event-driven платформы с учётом compliance и data retention требований.

Формирует стратегию использования Rust для критически важных messaging компонентов: проектирует Rust-based message router/proxy для multi-protocol поддержки, определяет архитектуру streaming-платформы с sub-millisecond latency. Контрибьютит в open-source messaging инфраструктуру (Fluvio, NATS).

Формирует streaming-стратегию для Scala-платформы: проектирует real-time processing pipeline с Apache Flink/Spark Structured Streaming на Scala, определяет architecture decision records для event sourcing vs traditional messaging. Влияет на развитие функционального подхода к messaging в Scala экосистеме.