Building stream processing applications for Apache Kafka using KSQL