KafkaGrupos de consumer e rebalance no Kafka com Spring Boot
Entenda como o Kafka distribui partições entre consumer groups, quando rebalance ocorre e como reduzir o impacto do rebalance em aplicações Spring Boot.
Change Data Capture com Debezium e Kafka
Use Debezium para ler o WAL do PostgreSQL, enviar todas as mudanças de dados para Kafka e consumi-las com Spring Boot, sem precisar modificar o código de escrita de dados.
Event sourcing com Kafka: guardar eventos em vez de estado
Use Kafka como event log para Order: registre eventos imutáveis, reconstrua o estado através de replay, crie read model com projection. Saiba as limitações antes de aplicar.
Kafka producer: acks, idempotência e batching
Configure acks, enable.idempotence, batch.size e linger.ms para Kafka producer para não perder mensagens, sem duplicatas e ainda atingindo alto throughput.
Monitorando Kafka: consumer lag e métricas essenciais
O que é consumer lag, como medir com CLI, AdminClient e Micrometer, quais métricas de broker/producer/consumer monitorar e como configurar alertas de forma apropriada.
Outbox pattern com Kafka: não perca eventos ao gravar
Gravar no banco de dados e enviar para o Kafka simultaneamente é fácil perder eventos. Este artigo guia a implementação do Outbox pattern com Spring Boot 3 e Kafka para manter consistência entre os dois.
Saga pattern com Kafka para transações distribuídas
Implemente o Saga pattern de tipo orchestration com Spring Boot e Kafka. Reserve voos, hotéis, processe pagamentos e compensação automática quando uma etapa falha.
Schema Registry e Avro/Protobuf em Kafka com Spring Boot
Utilize o Confluent Schema Registry com Avro e Protobuf no Spring Boot 3 para controlar o formato de mensagens Kafka e evoluir schemas de forma segura.
Consumer group e rebalance no Kafka: por que o consumer para
Como funciona o rebalance, por que faz o consumer parar de processar mensagens, e como minimizar com configuração de poll, rebalancing cooperativo, static membership.
Kafka retry e dead letter topic com Spring Kafka
Configure retry blocking e non-blocking para Kafka consumer no Spring Boot 3, encaminhe mensagens com erro para dead letter topic e escreva testes para verificar.
Projetando partition key no Kafka: ordenação de mensagens e balanceamento
Como Kafka seleciona partition a partir da key, como escolher a key para manter ordenação correta sem criar hot partitions, e erros comuns com Spring Boot.
Kafka Producer: acks, retry e idempotência correta
Entenda como acks, retries e idempotência funcionam juntos para garantir que mensagens não se percam, não se duplicam quando o producer envia dados para o Kafka.
Kafka Básico: Topic, Partition e Offset
Explicação dos três conceitos fundamentais do Kafka — topic, partition, offset — com exemplos de producer/consumer usando Spring Boot.