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

Имеет ли смысл создавать таблицу с Engine=Kafka и MV в

Distributed таблицу на каждом хосте кластера (на каждой реплике каждого шарда)?

8 ответов

18 просмотров

лучше не надо писать в Distributed (если у вас используется Replicated и не нужен шардинг по ключу) Engine=Kafka и MV конечно надо создавать на всех репликах

Vik-Kin Автор вопроса
Denny [Altinity]
лучше не надо писать в Distributed (если у вас исп...

как тогда размазывать данные по шардам? в MV прописывать условие выборки (аналог ключа шардирования)?

Vik Kin
как тогда размазывать данные по шардам? в MV пропи...

если нужен шардинг по ключу тогда конечно Distributed

Vik-Kin Автор вопроса
Denny [Altinity]
если нужен шардинг по ключу тогда конечно Distribu...

Вот, отсюда вопрос. Distributed таблица по логике одна на весь кластер, если на каждой реплике каждого шарда будет Engine=Kafka и MV TO Distributed, не будет ли дубликатов данных или еще каких проблем? Как я понимаю, каждая реплика с таблицой Engine=Kafka читает кафку под своим консьюмером, то есть каждая реплика достает из кафки свою копию данных, или это не так?

Vik Kin
Вот, отсюда вопрос. Distributed таблица по логике ...

Distributed конечно не одна на весь кластер. Каждая нода КХ независима, и таблицы Distributed на них независимы. >не будет ли дубликатов данных или еще каких проблем не будет. Просто создавайте все одинаково, на каждом ноде все 3 Kafka + MV + Distributed >каждая реплика с таблицой Engine=Kafka читает кафку под своим консьюмером, >то есть каждая реплика достает из кафки свою копию данных, или это не так это так, поэтому все ОК

Vik-Kin Автор вопроса
Denny [Altinity]
Distributed конечно не одна на весь кластер. Кажда...

спасибо большое :)) а internal_replication оставлять по умолчанию (false)?

Vik Kin
спасибо большое :)) а internal_replication оставля...

конечно он должен быть true при ReplicatedMergeTree иначе будут дубликаты internal_replication=true значит что внизу Replicated и она сама internally будет делать репликацию при internal_replication=false — репликацию делает Distributed (она пишет копию во все реплики)

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

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

Коллеги, я тут для личных нужд пошел ставить MQTT сервер, пощупал mosquitto, но ужаснулся отсутствию такой банальности, как HTTP API для посмотреть список топиков. А тут что,...
Maksim Lapshin
13
Всем привет! Имеется функция: function IsValidChar(ch: UTF8Char): Boolean; var i: Integer; ValidChars: AnsiString; begin ValidChars := 'abcdefghijklmnopqrstuvwxyzABCDE...
Евгений
44
#include <stdio.h> #include <stdlib.h> #include <time.h> void mass_first_generate(int mass[5][7]) {     for (int N = 0; N < 5; N++) {         for (int A = 0; A < 7; A++) {   ...
Чувак
6
Всем привет! Решаю 99 OCaml Problems и столкнулся со следующей проблемой (прошу палками не забивать, я OCaml практически не трогал до этого момента): open OUnit2 let create_...
К|/|pи/\/\ 6е3yглbIи
2
Ну вот просто даже давайте вот как. Какой нибудь конкретный кейс, можете в пример привести, где бч работает и приносит прикладную пользу, а не просто что бы было? Не крипту.
Alexander Andreev
22
https://www.linkedin.com/posts/ugama-benedicta-kelechi-codergirl-103041300_mobiledevelopment-fluttertraining-handsonlearning-activity-7263445699227254784-IdHB?utm_source=share...
CoderGirl
16
возможно ли как-то передать в электрон или таури медиа поток с рендера 2д движка? двиг запускается как dll, а дальше надо как-то отправлять рендер кодировать не подходит, зр...
Kyle Nekto
7
Точно, оно. У тебя там имена потоков выставляются?
Александр (Rouse_) Багель
11
Помогите пожалуйста. Делаю систему плагинов. Проблема сейчас в такая: плагины загружаются в основном потоке. FLibHandle := SafeLoadLibrary(FFileName) Но нужно еще выполнить фу...
Илья 🤣
10
объясните пожалуйста, почему функция не работает должным образом? вроде должно брать активное окно сравнивать его размер с размером экрана, и если есть совпадение = true прове...
JF
12
Карта сайта