Kafka Outbox ты настраивал самостоятельно?

Да, настраивал Kafka Outbox самостоятельно.

Kafka Outbox — это паттерн, который помогает гарантировать атомарность записи в базу данных и публикации событий в Kafka. Обычно реализуется через отдельную таблицу outbox в базе данных, куда записываются события вместе с основной транзакцией. Затем отдельный процесс читает эти события и публикует их в Kafka.

Примерный алгоритм настройки:

1. Создаётся таблица outbox с полями для хранения события (payload, тип, статус).
2. В транзакции вместе с основной бизнес-операцией записывается событие в outbox.
3. Отдельный воркер периодически читает новые записи из outbox и публикует их в Kafka.
4. После успешной публикации обновляет статус записи в outbox.

Это позволяет избежать рассинхронизации между базой и брокером сообщений.

В Go для этого можно использовать библиотеки для работы с Kafka (например, segmentio/kafka-go) и стандартные драйверы для работы с базой данных.