зачем его сбрасывать? он же сам сбрасывается на каждый блок данных
https://t.me/clickhouse_ru/291394 у меня вот такая ситуация думаю как себе помочь
увеличить этот лимит на пропуск битых сообщений не пробовали?
kafka engine не поддерживает alter (((
а что мешает сделать DROP + CREATE TABLE?
потеря данных в очереди
не забранные сообщения не коммитятся в кафку как вычитанные
хотите сказать, что данные не потеряются? я почему-то думал, что данные в КХ - это и есть данные кафки. то есть кафка использует КХ как таблицу для хранения данных в очереди.
всё совсем наоборот. вам надо как-то документацию почитать, видео посмотреть, чтобы разобраться, как там всё устроено
можете в двух словах пояснить про "наоборот". я не очень погружен в кафку. есть небольшой проект, который поддерживаю, поэтому знания поверхностные.
не выйдет в двух словах. вот это видео посмотрите от Альтинити, если английский понимаете: https://www.youtube.com/watch?v=f8GmRDdVJ-c
Обсуждают сегодня