Stream Processing Cookbook
The Stream Processing Cookbook includes a variety of stream processing tutorials and examples that you can use to quickly get started with KSQL.
Mask streaming data from an inbound topic that contains personally identifiable information (PII) and persist the output to a Kafka topic.
Filter streaming data from an inbound topic with KSQL to exclude records that originate from a particular geography.
Processing Syslog Data: Pattern Detection and Alerting
Enrich and filter syslog data with KSQL to detect anomalies in an infrastructure logging stream.
Topic Replica and Partition Count Manipulation
Change the properties of Kafka topics with KSQL by defining new streams with the desired properties of the new topic, populated by the streaming events of the original topic.
Event Time Processing
Event Time Processing
Define custom columns as providing the timestamp for time-based processing on messages.
Detecting and Analyzing Suspicious Network Activity
Analyze network traffic in real time and drive alerts based on suspect patterns with KSQL.
Enriching Streams with a Static JSON File Loaded as a Table
Enrich incoming streams with a static JSON file loaded as a table using a stream-table join.
Changing Data Serialization Format from Avro to CSV
Convert a topic from Avro to CSV with KSQL.
Derive data from an inbound stream with KSQL to concatenate the two columns together.
Inspecting and Changing Topic Keys
Update the key for an existing stream with KSQL.
Detecting Abnormal Transactions
Detect anomalous behavior from a stream of transactions by using multiple stream-table joins and window aggregations.
Derive data with KSQL from an inbound stream to calculate the difference between two dates.
Processing Syslog Data: Filtering
Enrich and filter syslog data of infrastructure logging events to detect possible malicious attacks.
Changing Data Serialization Format from JSON to Avro
Convert a topic from JSON to Avro with KSQL.
Route messages with KSQL from a source topic to multiple destination topics based on conditions in the data.
Working with Nested JSON Data
Learn how KSQL can work with JSON data that is nested.
Changing and Optimizing Partition Count
Specify the number of partitions that you want to use with KSQL.