本文介绍如何使用Kafka数据源进行数据分析或者交互式开发。

建表语法

CREATE TABLE tbName[(columnName dataType [,columnName dataType]*)]
USING kafka
OPTIONS(propertyName=propertyValue[,propertyName=propertyValue]*);

配置参数说明

参数名 说明 是否必选
subscribe 关联的Kafka Topic名称。 是
kafka.bootstrap.servers Kafka集群连接地址。 是