Matthias is a Software Engineer at Confluent where he works on Kafka Streams, Apache Kafka’s stream processing library. Prior to Confluent, Matthias was a PhD student at Humboldt-Universität zu Berlin, where he worked on data stream processing with Apache Flink and Apache Storm. He is a committer at both Flink and Storm.
Apache Kafka’s rise in popularity as a streaming platform has demanded a revisit of its traditional at least once message delivery semantics. In this talk, we present the recent additions to Apache Kafka to achieve exactly once semantics. We shall discuss the newly introduced transactional APIs and use Kafka Streams as an example to show how these APIs are leveraged for streams tasks.