{% include JB/setup %}
KSQL is the streaming SQL engine for Apache Kafka®. It provides an easy-to-use yet powerful interactive SQL interface for stream processing on Kafka,
N.b. The interpreter supports all the KSQL properties, i.e. ksql.streams.auto.offset.reset
. The full list of KSQL parameters is here.
In a paragraph, use %ksql
and start your SQL query in order to start to interact with KSQL.
Following some examples:
%ksql PRINT 'orders';
%ksql CREATE STREAM ORDERS WITH (VALUE_FORMAT='AVRO', KAFKA_TOPIC ='orders');
%ksql SELECT * FROM ORDERS LIMIT 10