Kafka 表引擎简介 对接 Kafka 系统,订阅 Kafka 主题,接收消息 创建 Kafka 引擎表 声明 1 2 3 4 5 6 7 8 9 10 11 ENGINE = Kafka() SETTINGS kafka_broker_list = 'host:port, ...', kafka_topic_list = 'topic1, topic2, ...', kafka_group_name = 'consumer_group_name', kafka_format = 'data_format', [kafka_row_delimiter = 'delimiter_symbol',] [kafka_schema = '',] [kafka_num_consumers = N,] [kafka_skip_broken_messages