This topic describes how to use Spark SQL to perform data analysis and interactive development on the Kafka data source.
CREATE TABLE syntax
CREATE TABLE tbName[(columnName dataType [,columnName dataType]*)]
USING kafka
OPTIONS(propertyName=propertyValue[,propertyName=propertyValue]*);Parameters
| Parameter | Description | Required |
|---|---|---|
| subscribe | The name of the associated Kafka topic. | Yes |
| kafka.bootstrap.servers | The connection address of the Kafka cluster. | Yes |