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

Подскажите про настройки интеграции с kafka: в Kafka SETTINGS есть опция:

kafka_group_name =
что в ней нужно выставлять?
Возможные варианты:
1) название группы инициатора сообщений того, кто пишет в kafka
2) везде писать clickhouse
3) везде должно быть свое название clickhouse_customname

В настоящий момент настраиваю три таблицы, что вытаскивают информацию из kafka ( каждая таблица из своего канала ), у меня везде было выставлено имя группы - clickhouse, в результате сообщения kafka переставали отображаться через запросы clickhouse ( через SELECT к таблице ) аккуратно после создания второй таблицы ( что вытаскивает информацию из kafka ). Сейчас же я в качестве группы указал уникальные для каждой таблицы название, и впервые добился, что все три таблицы вытаскивают информацию из kafka, параллельно друг другу, т.е. работают как и должны. Я немного почитал про идеологию kafka, но, ясности в отношении групп пока не возникло. Правильно ли в качестве группы указывать каждый раз кастомное имя, или же нужно указывать то, что прописано в группе инициатора сообщения? Влияют ли эти настройки на чистку сообщений внутри kafka?

2 ответов

7 просмотров

На самом деле это фичер Кафки, а не Кликхауса. Вкратце - название группы это ключ под которым Кафка хранит последний прочитанный оффсет в зукипере. Эти группы глобальные (не на топик). Про подробности - гуглите про Kafka consumer group .

по идее в продюсере не указывается группа а только имя топика, если 3 таблицы читают один и тот же топик то в зависимости от желайний группы могут быть : 1. хочется получить 3 копии таблицы - тогда все 3 имени должны быть разными 2. хочется разбить на ноды тогда имя должно быть одно и тоже

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

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

А чем вам питонисты не угодили?😂
.
79
Всем привет, написал код ниже, но он выдает сегфолт, в чем причина? #include <stdio.h> #include <stdlib.h> #include <string.h> struct product { char *name; float price; };...
buzz базз
75
Ещё такой вопрос. Мне необходимо хранить пароль пользователя локально. Для этого планирую использовать ini файл. Это для автозаполнения полей логин и пароль при авторизации. Е...
Евгений
19
Ты просто гитлеровскую эстетику плохо понимаешь. Он же всё под Цезаря делал. А это как бы запрещённый приём в политике. Пиджаки они зачем все носят? Чтобы показать что они тип...
Ivan Kropotkin
4
а чем лучше всего сделать глобальный лок, если много нодов, до сотни? ну то есть мне надо, чтобы некоторые операции с объектом не происходили одновременно. перемещение между н...
Д. П.
15
А как лучше конвертировать физический адрес в виртуальный при маппинге? В случае ядра у меня, например, direct mapping, первые 768МБ я как есть мапплю в higher half, а остальн...
Evg Resh
26
Hi guys, I'm looking for a good LLM course. Is there any course to learn LLMs in advanced? I'm aiming to use them in my apps, so a perfect course in my openion, is not only a ...
Taha
14
База данных не поможет. Шифрование не поможет. Какие там ещё варианты? Накидывайте.
КТ315
20
А табстоп это сообщение от окна или от элемента управления?
The Bird of Hermes
18
$params = [ 'formid' => 'feedbackForm', 'formTpl' => '@CODE: <form class="form-validate" data-id="ajax_form"> <fieldset class="margin-bottom-md"> ...
Pathologic
1
Карта сайта