KSQL: What’s New in 5.2 | Confluent

What this post added

This post introduces the CASE statement to KSQL, allowing for conditional logic within SQL queries. It demonstrates its use for data cleansing, deriving new columns, bucketing data based on ranges, masking sensitive information, inferring missing values, generating conditional aggregates, and routing traffic for A/B testing. Additionally, it details how to configure KSQL to log processing errors to a Kafka topic for improved observability.