Understanding Stream Table Duality Using Kafka, Flink SQL and Debezium Format

Kafka Streams, ksqlDB or Flink SQL are popular processing engines that enable us to run SQL queries on top of streaming data. Isn't it fascinating that we can run SQL queries on top of streaming data as if they were relational tables, or convert a table into a stream of changelog events? This is known as the stream-table duality.  

  In this talk we will try to understand how it works under the hood using Flink SQL, Kafka connector with Debezium JSON/Avro format.  

  The following points will be presented and discussed:  

  - What is stream-table duality?  

- Change data capture (CDC) event descriptions  

- SQL queries on top of changelog data  

- Short Demo  

- Conclusion and Q&A  

  At the conclusion of the presentation, the attendees will possess a more comprehensive understanding of stream-table duality, how it works in practice, and how to apply it into their own systems.