spring-kafka-integration

What problem does it solve?

This skill provides a cohesive pattern for integrating Apache Kafka with Spring Boot applications, enabling reliable event-driven messaging, with support for both blocking Spring Kafka and reactive Reactor Kafka pipelines.

Core Features & Use Cases

• Producer/Consumer integration: Standardizes Spring KafkaTemplate usage and @KafkaListener patterns for both blocking and reactive modes.
• DLT & retries: Configures Dead Letter Topics and robust retry/backoff strategies to handle processing failures.
• Transactional Outbox & Event Sourcing: Supports transactional outbox patterns and event sourcing to ensure exactly-once or at-least-once semantics in distributed systems.
• Reactive streaming: Provides Reactor Kafka integration for WebFlux-based apps with backpressure-aware flows.
• Testing & patterns: Patterns for idempotent producers and test strategies (EmbeddedKafka, Testcontainers).

Quick Start

• Use this skill alongside the backend-developer skill to implement Kafka-based event flows in a Spring Boot project.
• Example tasks include configuring KafkaTemplate producers, @KafkaListener consumers, DLT handling, and transactional outbox integration.
• Validate with tests using Embedded Kafka or Testcontainers to simulate real Kafka interactions.