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

References

For more information about the Kafka data source, see Structured Streaming + Kafka Integration Guide.