Дебезиум не указывает на завершение передачи прямо сейчас.План на будущее состоит в том, чтобы включить порядковый номер для каждого изменения в транзакции и указать, какая запись является последней.После этого должно быть легко объединить изменения обратно в одно сообщение.
В качестве временного решения вы можете использовать окна сеансов Kafka Streams, где идентификатором сеанса будет идентификатор транзакции (GTID).