skills.rest
olehsvyrydov
olehsvyrydovCOMMUNITY
Explore all skills by this author →
GitHub

spring-kafka-integration

Configure Spring Kafka producers, consumers, and Dead Letter Topics in Spring Boot applications.

13|6|Updated Dec 23, 2025
Search Tags:#event-driven#transactional-outbox#dead-letter-topic#reactor-kafka#kafka-testing#spring-kafka
One-click install
npx skills add https://github.com/olehsvyrydov/AI-development-team --skill spring-kafka-integration
Or copy as Structured Prompt for Agent▼
Please help me install this Agent Skill.
Skill: spring-kafka-integration
Source: https://github.com/olehsvyrydov/AI-development-team/tree/main/claude/skills/development/backend/java/spring-kafka
Command: npx skills add https://github.com/olehsvyrydov/AI-development-team --skill spring-kafka-integration

SYSTEM DOCUMENTATION & REQUIREMENTS

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.

Frequently Asked Questions about spring-kafka-integration

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I configure a transactional outbox with Spring Kafka?▼

To configure a transactional outbox with Spring Kafka, you apply event sourcing patterns that ensure exactly-once or at-least-once delivery semantics. This coordinates database writes and Kafka producer events within a single transactional boundary.

How do I handle processing failures using a Dead Letter Topic in Spring Boot?▼

Handling processing failures with a Dead Letter Topic in Spring Boot involves configuring robust retry and backoff strategies. Failed messages are routed to a DLT, isolating unprocessable events without blocking the main consumer pipeline.

Can I use Reactor Kafka for backpressure-aware streaming in Spring WebFlux?▼

Yes, you can use Reactor Kafka for backpressure-aware streaming in Spring WebFlux. It provides reactive pipeline integration for WebFlux-based applications, enabling non-blocking event flows with Reactor Kafka 1.3.x.

What is the best way to test Kafka consumers and producers in Spring Boot 3.x?▼

The best way to test Kafka consumers and producers in Spring Boot 3.x is using EmbeddedKafka or Testcontainers. These tools simulate real Kafka interactions to validate idempotent producers and verify event contracts.

Does Spring Kafka support both blocking and reactive messaging pipelines?▼

Yes, Spring Kafka supports both blocking and reactive messaging pipelines. It standardizes KafkaTemplate usage and @KafkaListener patterns for blocking applications, while providing Reactor Kafka integration for reactive streams.

Related Skills

Explore More Software Engineering Skills→
dallaydallay
1

spring-boot-messaging

Guide event-driven messaging and reactive integration in Spring Boot 4 applications.

Official
Advanced
finsilabsfinsilabs
44

shopify-webhooks

Register and process Shopify webhook events with HMAC validation and idempotency.

Official
Advanced
MassimilianoPiliMassimilianoPili

spring-boot-event-driven-patterns

Implement Event-Driven Architecture in Spring Boot 3.x with Kafka and Spring Cloud Stream.

Community
Advanced
vuralserhat86vuralserhat86
43

message_queues

Implements asynchronous communication patterns using Kafka, RabbitMQ, NATS, Redis Streams, Celery, BullMQ, Temporal, and more.

Community
Advanced