кх не может распарсить входные данные ( неверный формат даты и тп)? Он скипает только эту строку? Наблюдал вчера картину что при наличии кривых данных какие то записи попадали в кх, но при этом офсет в кафку не комитился, до тех пор пока блок целиком не оказался валидным. Версия 18.16
Это старая версия, и там действительно такое поведение: кх "завивает" на пачке с битым сообщением и ничего не коммитит, а сообщения перед битым могут несколько раз вставляться.
Обсуждают сегодня