Visão Geral

Este curso avançado aprofunda o uso do Kafka Streams para construção de aplicações distribuídas, resilientes e de alto desempenho voltadas para processamento de eventos em tempo real. Você aprenderá técnicas avançadas de stateful processing, otimização, interações com armazenamento, topologias complexas, padrões arquiteturais e práticas de produção utilizadas em grandes empresas.

Objetivo

Após realizar este curso, você será capaz de:

• Projetar topologias avançadas com múltiplos processadores
• Criar pipelines stateful com stores otimizados
• Utilizar padrões avançados de windowing e joins complexos
• Escalar, particionar e otimizar aplicações Kafka Streams
• Implementar fault tolerance, resiliência e testes de alta cobertura
• Preparar e monitorar aplicações em ambiente de produção

Publico Alvo

• Engenheiros de Dados
• Desenvolvedores Backend
• Arquitetos de Software
• Profissionais que já utilizam Kafka Streams em nível básico
• Especialistas em sistemas de streaming e event-driven

Pre-Requisitos

• Kafka Streams básico
• Conhecimento intermediário de Java
• Compreensão de tópicos Kafka, particionamento e consumer groups
• Noções de arquitetura distribuída

Conteúdo Programatico

Module 1 — Advanced Kafka Streams Architecture

1. Deep dive into Streams DSL and Processor API
2. Threading model and internal consumer/producer behavior
3. Managing tasks and partitions

Module 2 — Advanced State Management

1. State stores deep analysis
2. RocksDB advanced configuration
3. Logging, caching, and state recovery
4. Fault tolerance and standby replicas

Module 3 — Complex Topologies

1. Multi-processor topologies
2. Branching, merging and repartitioning
3. Topology optimization techniques

Module 4 — Advanced Joins & Windows

1. Stream–stream joins with strict ordering
2. Stream–table and table–table joins
3. Windowing with custom grace periods
4. Handling late and out-of-order events

Module 5 — High-Performance Kafka Streams

1. Throughput optimization
2. Memory tuning and cache strategies
3. RocksDB compaction tuning
4. Reducing rebalancing overhead

Module 6 — Error Handling & Resilience

1. Retry strategies & dead-letter topics
2. Handling corrupted events
3. Graceful degradation patterns

Module 7 — Interactive Queries & External Access

1. Exposing state stores
2. Queryable state patterns
3. Access via REST and microservices

Module 8 — Testing Kafka Streams Applications

1. Unit tests with TopologyTestDriver
2. Integration testing strategies
3. Mocking state stores and external systems

Module 9 — Deploying Kafka Streams in Production

1. Best deployment patterns
2. Running Streams apps in containers
3. Horizontal scaling approaches
4. Rolling upgrades & version migration

Module 10 — Observability & Monitoring

1. Metrics and health checks
2. Integrating with Prometheus & Grafana
3. End-to-end tracing

Module 11 — Real-World Patterns

1. Event sourcing with Kafka Streams
2. CQRS using streams & tables
3. Change propagation patterns
4. Designing large-scale event-driven systems

Module 12 — Capstone Project

1. Build an advanced real-time application
2. Multi-join + windowing + external queries
3. Production-ready deployment
4. Performance evaluation and documentation