CREATE TABLE kafka (
 DATA String,
) ENGINE = Kafka;
CREATE TABLE data_from_kafka (
    DATA String
) ENGINE = MergeTree;
CREATE MATERIALIZE VIEW mv_data_from_kafka TO data_from_kafka AS SELECT * FROM kafka;