Я читаю внутренности debezium, но он также может посылать дубликаты сообщений на kafka, если в коннекторе есть какой-то сбой перед обновлением смещения в журнале bin. В этом случае потребитель должен быть идемпотентом. Есть ли способ избежать дублирования сообщений в кафке ??