How to build a streaming application with KSQL ? Syntax is very similar to SQL.
KSQL Basics - Why ?
KSQL Basics - How ?
Everything starts with the Kafka cluster since it is the core of the streaming platform.
KSQL
CREATE STREAM streamName AS
SELECT col1, col2, col3
FROM source
WHERE type = '…'
Kafka Streams
.to(“streamName“)
.mapValues(source → source.getCol1() + “,“ + source.getCol2() + “,“ + source.getCol3())
.stream(“source“)
.filter(source → source.getType().equals(“..“))