Коллеги, извините, повторяю вопрос, ибо актуально
Кратко: Создаем table engine=kafka, создаем materialized view .. to ... для доставки данных из топика в таблицу. Данные не идут, нигде никаких ошибок не вижу. Если делать вставку
insert into historyvalues select ... (запрос идентичный MV)
то данные вставляются.
Где искать проблему? Куда, в какие логи смотреть?
Пространно:
Создаем очередь
CREATE TABLE queue
(
value String
)
ENGINE = Kafka
SETTINGS kafka_broker_list = '192.168.XX.XX:9092',
kafka_topic_list = 'topicQueueTest',
kafka_group_name = 'group1',
kafka_format = 'LineAsString';
Создаем matview
CREATE MATERIALIZED VIEW IF NOT EXISTS
HistoryValuesMV TO historyvalues
AS SELECT toInt64(b.idtag) as IdTag
, b.valueFloat as valueFloat
, b.valueString as valueString
, b.timestamp as timestamp
, now() as timestampWT
from (select a.idtag
, (data.1) as valueFloat
, (data.2) as valueString
, fromUnixTimestamp64Milli((data.3),'UTC') as timestamp
from
(select _key as idtag
, JSONExtract(value||']','Array(Tuple(VF Nullable(Float64),VS Nullable(String),TS Int64))') as data
from queue) a
array join
a.data as data) b;
Данные не идут, нигде никаких ошибок не вижу. Если делать вставку
insert into historyvalues select ... (запрос идентичный MV)
то данные вставляются.
Где искать проблему? Куда, в какие логи смотреть?