Как оркестрировался бизнес-флоу в микросервисах на последней работе

Мы использовали Apache Kafka в качестве event-driven шины для оркестрации бизнес-процессов. Каждый сервис публиковал события после выполнения своей части workflow, а другие сервисы подписывались на релевантные события.

Пример:

// OrderService публикует событие
kafkaTemplate.send("order.created", 
    new OrderCreatedEvent(orderId, customerId));

// PaymentService подписан на это событие
@KafkaListener(topics = "order.created")
public void handleOrderCreated(OrderCreatedEvent event) {
    paymentService.processPayment(event.getOrderId());
}

Для сложных саг использовали паттерн Saga с компенсирующими транзакциями. Хореография предпочтительнее централизованной оркестрации из-за меньшей связанности.