World Congress 2021 • Jun 30, 2021

Kafka Streams Microservices

Denis Washington , Olli Salonen

Replacing tightly coupled microservices with Kafka Streams guarantees continuous data availability. Learn to build resilient, event-sourced architectures by treating Kafka as primary persistent storage.

Pause
Mute Enter Fullscreen
#1 about 2 min

Overcoming integration challenges with Kafka Streams microservices

Designing a robust platform to integrate disconnected cloud systems without building monolithic data silos.

#2 about 4 min

Core concepts of Apache Kafka and topic topologies

Understanding the fundamental mechanics of distributed event logs, consumer offsets, and stream topology abstractions.

#3 about 6 min

Transitioning from synchronous microservices to event sourcing

Replacing direct commands and system querying with primary event streams to eliminate tight coupling.

#4 about 4 min

Designing stream topologies and managing system failure scenarios

Leveraging stored event logs to replay historical data and maintain data read availability during outages.

#5 about 4 min

Building a consistent product catalog stream data pipeline

Aggregating, cleaning, and enriching unreliable inbound event streams into an interactive full-text search view.

#6 about 9 min

Solving race conditions and distributed state with repartitioning

Restructuring Kafka topics and IDs to enforce synchronous property validations across concurrent backend processors.

#7 about 4 min

Automating system behavior across independent event data streams

Writing processor topologies that combine separate state entities to trigger automated actions without API orchestration.

#8 about 5 min

Operational complexities and performance optimization of stream applications

Overcoming deployment pitfalls arising from transactional properties and overriding shared configurations under heavy loads.

#9 about 2 min

Blending traditional relational databases with event driven streams

Hooking classic database engines up to log publisher connectors to simplify complex unique entity logic.

#10 about 11 min

Exploring query boundaries, data storage, and architecture limits

Clarifying the practical boundaries of local processing safety, testing frameworks, and scalable long-term message compaction.

Matching moments

2:20 min

Event streaming and distributed systems with Apache Kafka

Sandon Jacobs Sandon Jacobs · World Congress 2026 North America

2:00 min

Moving from traditional databases to decoupled event streaming

Gerard Klijs · LIVE

5:43 min

Processing real-time event streams with Apache Kafka

Alex Soto Alex Soto · LIVE

3:45 min

Reviewing core Apache Kafka architecture and distributed fundamentals

Kirill Kulikov · LIVE

4:30 min

Introducing data management and the shift to streaming

Mary Grygleski Mary Grygleski · LIVE

1:56 min

Overview of current stream processing frameworks

Hartmut Armbruster Hartmut Armbruster · World Congress 2026 Europe

Upcoming sessions on this topic

Open session

How We Cut Our API's p99 Latency from Minutes to Under a Second

  • Deepak Agrawal

    Atlassian

    Principal Software Engineer

Open session

React Under Fire: Rendering Performance for Streaming Agent UIs

  • Abhirupa Mitra

    Slack

    Senior Member of Technical Staff

Open session

Multi-Cloud Isn't a Project. It's a Side Effect.

  • Antonio Mendoza Pérez

    Temporal Technologies

    Staff Developer Success Engineer

  • Gaurav Thadani

    Temporal

    Staff Developer Success Engineer

Open session

We Deleted Our Observability Stack and Rebuilt It with OTEL: 12 Engineers to 4 at 20K+ clusters

  • Yash Sharma

    DigitalOcean

    Developer Advocate

Open session

What I Got Wrong Shipping an MCP Server for Live Infrastructure

  • Pritesh Kiri

    Harness

    Developer Relations Engineer

Open session

Architecting Trusted AI: Coupling Multi-Agent Systems with dbt Semantic Store for Zero-Hallucination

  • Pushkar Mishra

    J.P. Morgan

    Senior Vice President