KafkaConsumer group y rebalance en Kafka con Spring Boot
Comprende cómo Kafka asigna particiones al consumer group, cuándo ocurre el rebalance y cómo reducir su impacto en aplicaciones Spring Boot
Change Data Capture con Debezium y Kafka
Usa Debezium para capturar cambios de PostgreSQL, envíalos a Kafka y consume con Spring Boot, eliminando el riesgo del dual-write.
Event sourcing con Kafka: guardar eventos en lugar de estado
Usa Kafka como event log para Order: registra eventos inmutables, reconstruye el estado con replay, crea read models con projection. Incluye limitaciones que debes conocer antes de aplicar.
Kafka producer: acks, idempotencia y batching
Configura acks, enable.idempotence, batch.size y linger.ms en Kafka producer para no perder mensajes, evitar duplicados y alcanzar alto throughput.
Monitoreo de Kafka: consumer lag y métricas clave
Qué es el consumer lag, cómo medirlo con CLI, AdminClient y Micrometer, qué métricas del broker/productor/consumidor debes vigilar, y cómo establecer alertas efectivas.
Outbox pattern con Kafka: no pierdas eventos al escribir
Escribir en base de datos y enviar a Kafka simultáneamente pierde eventos fácilmente. Este artículo enseña a implementar Outbox pattern con Spring Boot 3 y Kafka para mantener coherencia.
Patrón Saga con Kafka para transacciones distribuidas: ejemplo de reserva de tours
Implementa el patrón Saga de orquestación con Spring Boot y Kafka. Reserva vuelos, hoteles, pagos, y compensa automáticamente cuando un paso falla.
Schema Registry y Avro/Protobuf en Kafka con Spring Boot
Usa Confluent Schema Registry con Avro y Protobuf en Spring Boot 3 para controlar el formato de mensajes Kafka y evolucionar esquemas de forma segura.
Consumer group y rebalance en Kafka: por qué se detienen
Cómo funciona el rebalance, por qué detiene el procesamiento de mensajes en los consumidores, y cómo minimizarlo mediante la configuración de poll, rebalance cooperativo y membresía estática.
Diseño de partition key en Kafka: orden de mensajes y distribución de carga
Cómo Kafka elige la partición a partir de la clave, cómo elegir la clave para mantener el orden correcto de mensajes sin crear particiones calientes, y errores comunes con Spring Boot.
Kafka retry y dead letter topic con Spring Kafka
Configura reintentos bloqueantes y no bloqueantes para consumidores Kafka en Spring Boot 3, envía mensajes con error al dead letter topic y escribe tests de verificación.
Producer Kafka: acks, retries e idempotencia correctamente
Descubre cómo acks, retries e idempotencia trabajan juntos para garantizar que los mensajes no se pierdan ni se dupliquen cuando el producer envía datos a Kafka.
Kafka Básico: Topic, Partition y Offset
Explicación de tres conceptos fundamentales de Kafka — topic, partition, offset — con ejemplos de producer/consumer usando Spring Boot.