Rathnadevi Manivannan shows how to use Kafka SQL to query streaming data:
Kafka SQL, a streaming SQL engine for Apache Kafka by Confluent, is used for real-time data integration, data monitoring, and data anomaly detection. KSQL is used to read, write, and process Citi Bike trip data in real-time, enrich the trip data with other station details, and find the number of trips started and ended in a day for a particular station. It is also used to publish trip data from the source to other destinations for further analysis.
In this article, let’s discuss enriching the Citi Bike trip data and finding the number of trips on a particular day to and from a particular station.
Read on for a nice tutorial.