Что такое pattern outbox?

Outbox pattern решает проблему надежной доставки сообщений при работе с базой данных и брокером сообщений.

Проблема:
Как гарантировать, что сообщение будет отправлено в broker только если бизнес-транзакция успешно завершена?

Решение Outbox pattern:

1. Сохранение в outbox таблицу:

   BEGIN TRANSACTION;
   
   -- Бизнес-операция
   INSERT INTO orders (id, amount) VALUES (1, 100);
   
   -- Сохранение сообщения
   INSERT INTO outbox (id, topic, payload) 
   VALUES (gen_random_uuid(), 'order-created', '{"orderId": 1}');
   
   COMMIT;

2. Отдельный процесс (poller):

   • Периодически проверяет таблицу outbox

   • Отправляет новые сообщения в брокер

   • Помечает отправленные сообщения как обработанные

Преимущества:

• Гарантирует exactly-once семантику

• Избегает распределенные транзакции

• Обеспечивает надежность доставки

Реализация с Debezium:
Можно использовать Change Data Capture (CDC) инструменты для автоматического чтения из outbox.