что-то делаю не так?
over чта?
Ну произвольная колонка
а что вы делаете?
Денис, доброй ночи. Подскажите пожалуйста вы когда вычитываете kafka через CH сильно тюните от дефолтных настроек и кафку и CH если нагрузка на кафку примерно такая по трем основным топикам: сообщений в минуту. Суть проблемы в том, что случается иногда ребалансировка топиков и в сообщениях CH вижу ворнинги что он не может приасайнится к партиции либо такой Consumer group session timed out (in join-state steady) after 312742 ms without a successful response from the group coordinator (broker 2, last error was Broker: Unknown member): revoking assignment and rejoining group
select x, number, row_number() over ( partition by x ) from (select number%3 x, number from numbers(10)); ┌─x─┬─number─┬─row_number() OVER (PARTITION BY x)─┐ │ 0 │ 0 │ 1 │ │ 0 │ 3 │ 2 │ │ 0 │ 6 │ 3 │ │ 0 │ 9 │ 4 │ │ 1 │ 1 │ 1 │ │ 1 │ 4 │ 2 │ │ 1 │ 7 │ 3 │ │ 2 │ 2 │ 1 │ │ 2 │ 5 │ 2 │ │ 2 │ 8 │ 3 │ └───┴────────┴────────────────────────────────────┘
зависит от жирности сообщений, сообщения бывают 3 поля, а бывают 600 полей. у вас либо летенси до брокера, либо брокеры тормозят.
Обсуждают сегодня