Как решить проблему гарантированной записи данных в базу и одновременной отправки сообщения в Kafka (dual write), в том числе если бэкенд отправляет сообщение в очередь и нужно гарантировать, что оно не потеряется при ошибке очереди или сети?