Привет, никто не сталкивался с проблемой, что при чтении из kafka, clickhouse получаю ошибку
Code: 190, e.displayText() = DB::Exception: Elements 'string_fields.names' and 'string_fields.values' of Nested data structure 'string_fields' (Array columns) have different array sizes., Stack trace (when copying this message, always include the lines below) (отправили некорректные данные в kafka)
Я думал при значении kafka_skip_broken_messages = 1 сообщение просто пропуститься должно, но оно каждый раз пытается вставиться в бесконечном цикле
Есть еще какие-либо опции у Kafka Engine пропускать невалидные сообщения?
kafka_skip_broken_messages – максимальное количество некорректных сообщений в блоке. Если kafka_skip_broken_messages = N, то движок отбрасывает N сообщений Кафки, которые не получилось обработать.
может, у Вас там больше одного такого сообщения в пачке приходит?