Rethinking Stream Processing with Apache Kafka, Kafka Streams and KSQL

I presented at JavaLand 2018 in Brühl recently. A great developer conference with over 1800 attendees. The location is also awesome! A theme park: Phantasialand. My talk: “New Era of Stream Processing with Apache Kafka’s Streams API and KSQL“. Just want to share the slide deck…

Abstract

Stream Processing is a concept used to act on real-time streaming data. This session shows and demos how teams in different industries leverage the innovative Streams API from Apache Kafka to build and deploy mission-critical streaming real time application and microservices.

The session discusses important Streaming concepts like local and distributed state management, exactly once semantics, embedding streaming into any application, deployment to any infrastructure. Afterwards, the session explains key advantages of Kafka’s Streams API like distributed processing and fault-tolerance with fast failover, no-downtime rolling deployments and the ability to reprocess events so you can recalculate output when your code changes.

A demo shows how to combine any custom code with your streams application – by an example using an analytic model built with any machine learning framework like Apache Spark ML or TensorFlow.

The end of the session introduces KSQL – the open source Streaming SQL Engine for Apache Kafka. Write “simple” SQL streaming queries with the scalability, throughput and fail-over of Kafka Streams under the hood.

Slide Deck

Here we go:

https://www.slideshare.net/KaiWaehner/rethinking-stream-processing-with-apache-kafka-kafka-streams-and-ksql

 

Kai Waehner

bridging the gap between technical innovation and business value for data integration, workflow orchestration, and agentic AI.

Share
Published by
Kai Waehner

Recent Posts

Data Integration vs Workflow Orchestration: Connecting Systems Is Not Coordinating the Work

Data integration and workflow orchestration get confused because both ship hundreds of connectors. This post…

1 week ago

Process Intelligence Landscape 2026: Mining, Orchestration, and the Agentic AI Shift

Process intelligence has become three things, not one: mining, orchestration, and a decision gate. Here…

2 weeks ago

When to Use AMQP, JMS, Kafka, or MQTT: Trade-offs, Not a Winner

AMQP, JMS, Kafka, and MQTT get compared as rivals, but a message broker, a log,…

3 weeks ago

Kafka vs Flink vs Spark: Do You Really Need Real-Time?

Most vendors sell milliseconds, but most enterprise use cases do not need them. A critical…

3 weeks ago

Edge to Cloud and Back: Four Data Movement Problems, and Why One Technology Never Solves All of Them

Edge to cloud is not one integration problem. It is four: telemetry going up, control…

4 weeks ago

Data Integration Landscape 2026: Event Streaming, API, and Batch in the Era of Agentic AI

The Data Integration Landscape 2026 maps every major vendor across three communication paradigms: request-response, event-driven,…

4 weeks ago