184 похожих чатов

Приветствую! Столкнулся со странным поведением Kafka движка в версии 22.1.3.7. Таблица

вида:
Create table table_kafka_out
(
field1 String,
field2 String,
field3 String
) engine = Kafka
SETTINGS kafka_broker_list = ‘broker’, kafka_topic_list = ‘topic’, kafka_group_name = ‘group’, kafka_format = ‘JSONEachRow’

Топик на 5 партиций, replication-factor = 1.

При INSERT в таблицу ожидаемое поведение - равномерно размазанные по партициям сообщения. Реальное поведение - 90% сообщений уходит в первую партицию, остальные неравномерно размазываются по оставшимся четырём.

Пробовал читать из клика и своим продюсером кидать в тот же топик - распределяет равномерно.

На версии 21.х(уже точно не помню) таких проблем не замечал.

Может я не знаю каких-то настроек? Такое ощущение, что используется не round-robin распределение, а что-то другое.

4 ответов

11 просмотров

Прошу прощения, что вопросом на вопрос, но разве этот движок ClickHouse умеет писать в Kafka?

1- Автор вопроса

Повторю вопрос, тк проблема не решена. Важные уточнения: ключа в сообщении нет. Сама кафка точно работает корректно и другой продюсер(не кх) пишет в тот же топик равномерно(round-robin распределение).

Похожие вопросы

Обсуждают сегодня

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта