IF NOT EXISTS kafka ON CLUSTER '{cluster}' (
field1 String,
field2 Nullable(String),
field3 Nullable(String)
)
ENGINE = Kafka
SETTINGS
kafka_broker_list = 'broker',
kafka_topic_list = 'topic',
kafka_group_name = 'group',
kafka_format = 'JSONEachRow'
С неё данные забирают 2 MV.
Одна при условии что field2 и field3 is NULL, вторая что field2 и field3 is not NULL.
Не будет ли при таком варианте "потери" сообщений?
не будет
Обсуждают сегодня