本文介绍如何使用Kafka数据源进行数据分析或者交互式开发。
建表语法
CREATE TABLE tbName[(columnName dataType [,columnName dataType]*)]
USING kafka
OPTIONS(propertyName=propertyValue[,propertyName=propertyValue]*);配置参数说明
| 参数名 | 说明 | 是否必选 |
|---|---|---|
| subscribe | 关联的Kafka Topic名称。 | 是 |
| kafka.bootstrap.servers | Kafka集群连接地址。 | 是 |
相关文档
Kafka数据源详细文档，请参见Structured Streaming + Kafka Integration Guide。