World Congress 2024 Aug 20, 2024 Session details

Why and when should we consider Stream Processing frameworks in our solutions

Soroosh Khodami

Are you over-engineering your data pipeline? Learn when to leverage complex stream processing frameworks like Apache Flink, and when simple SQL micro-batching is the smarter architectural choice.

Pause
Mute Enter Fullscreen
#1 about 3 min

Defining stream data processing versus standard event processing

Differentiating continuous data aggregation from discrete message decision making.

#2 about 3 min

Handling message order with event and processing time

Analyzing data by actual event occurrence to guarantee offline state consistency.

#3 about 3 min

Ensuring exactly once message delivery in distributed systems

Utilizing stream framework checkpoint mechanisms to completely avoid duplicate data processing.

#4 about 3 min

Constructing data pipelines with stream processing architecture operators

Connecting basic operator functions to correctly read, transform, and sync continuous inputs.

#5 about 6 min

Applying windowing functions to segment unbounded data streams

Segmenting unbounded continuous data streams using distinct tumbling, sliding, and session windows.

#6 about 4 min

Joining data streams and managing stateful memory processing

Combining separate message sources and retaining critical memory state for complex temporal analytics.

#7 about 2 min

Evaluating mature stream processing frameworks for production systems

Reviewing industry-standard data tools like Apache Flink and Beam for scalable application architecture.

#8 about 5 min

Comparing performance and complexity against standard microservice architectures

Benchmarking Apache Beam data pipelines against Spring Boot to assess throughput and setup overhead.

#9 about 3 min

Assessing the organizational cost of stream framework adoption

Weighing high execution speed against steep learning curves and heavy engineering maintenance bandwidth.

#10 about 1 min

Identifying real-world applications for stream processing technology usage

Exploring practical data implementations across gaming anti-cheat systems, telecommunications, and financial fraud detection.

#11 about 2 min

Establishing adoption prerequisites and business stakeholder strategic alignment

Ensuring transparent business requirements exist before committing complex engineering logic to pipeline structural changes.

Matching moments

1:33 min

Overcoming typical barriers to real-time stream processing adoption

Bobur Umurzokov · LIVE

1:56 min

Overview of current stream processing frameworks

Hartmut Armbruster Hartmut Armbruster · World Congress 2026 Europe

4:14 min

Recognizing architectural drivers pushing event streaming system adoption

Mary Grygleski Mary Grygleski · LIVE

4:30 min

Introducing data management and the shift to streaming

Mary Grygleski Mary Grygleski · LIVE

1:32 min

Comparing stream processing architecture to traditional batch processing

Bobur Umurzokov · LIVE

4:38 min

Operational complexities and performance optimization of stream applications

Denis Washington +1 · World Congress 2021

Upcoming sessions on this topic

Open session

World Congress 2026 North America

September 24, 2026 · 14:10–14:40

Stage 3

Real-Time Data Platforms at Trillion-Event Scale

Diptamay Sanyal

Principal Engineer | Data, AI & Cybersecurity Platforms

Diptamay Sanyal
Open session

World Congress 2026 North America

September 25, 2026 · 12:55–13:25

Stage 3

Replay-Safe Architecture: Building Event-Driven Systems That Can Recover With Confidence

Ishan Shah

PayPal, Software Engineer | Distributed Systems, AI, and Platform Engineering

Ishan Shah
Open session

World Congress 2026 North America

September 25, 2026 · 09:00–09:30

Stage 7

AI Agents are Only as Smart as their Context: Building a Real-Time Context Engine at Intuit

Bharat Patel

Lead Software Engineer at Intuit

Bharat Patel
Open session

World Congress 2026 North America

September 24, 2026 · 16:50–17:20

Stage 9

From Guesswork to Governance: Data Contracts Bring API Discipline to Apache Kafka

Sandon Jacobs

Senior Developer Advocate at IBM

Sandon Jacobs
Open session

World Congress 2026 North America

September 24, 2026 · 17:30–18:00

Stage 3

Scaling Distributed Queues for AI workloads

Jasmit Kaur Saluja

Software Engineer at Meta Platforms Inc

Jasmit Kaur Saluja
Open session

World Congress 2026 North America

September 24, 2026 · 11:00–11:30

Stage 2

From Stateless to Stateful: Real-Time Voice & Messaging Agents with Twilio and AWS

Rishab Kumar

Staff Developer Evangelist @ Twilio

Rishab Kumar