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 |