KSQL Interpreter for Apache Zeppelin

Overview

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,

Configuration

Property Default Description
ksql.url http://localhost:8080 The KSQL Endpoint base URL

N.b. The interpreter supports all the KSQL properties, i.e. ksql.streams.auto.offset.reset. The full list of KSQL parameters is here.

Using the KSQL Interpreter

In a paragraph, use %ksql and start your SQL query in order to start to interact with KSQL.

Following some examples:

%ksql
PRINT 'orders';

PRINT image

%ksql
CREATE STREAM ORDERS WITH
  (VALUE_FORMAT='AVRO',
   KAFKA_TOPIC ='orders');

CREATE image

%ksql
SELECT *
FROM ORDERS
LIMIT 10

LIMIT image