У меня есть стриминговая работа по чтению сообщений в формате Json из темы кафки.Сценарий: чтение из темы kafka и запись в таблицу кустов, где я включил автоматическую фиксацию смещения как true.
Проблема: если моя работа не выполняется при записи данных в таблицу кустов, я теряю эти записи.Как мне восстановить эти данные или есть ли способ убедиться, что данные не будут потеряны при потоковой передаче по теме?