Build Spring Kafka producers and consumers with retry, DLT, and embedded Kafka tests.
npx skills add https://github.com/ririnto/sinon --skill spring-kafka-ririnto
Please help me install this Agent Skill. Skill: spring-kafka Source: https://github.com/ririnto/sinon/tree/main/plugins/spring/skills/spring-kafka Command: npx skills add https://github.com/ririnto/sinon --skill spring-kafka-ririnto
Building Spring Kafka apps can be verbose; this skill provides a guided pattern to implement Kafka producers and consumers using Spring's KafkaTemplate and @KafkaListener, with clear boundaries for retries, dead-lettering, and testing.
Create a Spring Boot project, configure Spring Kafka with a KafkaTemplate and a @KafkaListener, and add a basic retry/Dead-Letter setup with an embedded Kafka test.
High-intent search queries and answers about installing and using this skill.
Configuring a KafkaTemplate and @KafkaListener in Spring Boot involves declaring topics, setting up Spring Kafka 4.x properties, and annotating listener methods to process incoming messages. This approach streamlines building reliable producers and consumers for microservices.
Implementing retry and dead-letter topics in Spring Kafka requires configuring specific error-handling policies within your @KafkaListener setup. This ensures failed messages are automatically retried and eventually routed to a DLT for reliable microservices messaging.
Testing Kafka producer and consumer flows with embedded Kafka involves setting up an embedded Kafka test environment within your Spring Boot tests. This validates end-to-end message processing, retry logic, and DLT routing without needing an external broker.
Yes, Spring Kafka 4.x supports centralized topic declaration and management. You can programmatically declare and manage your Kafka topics within your Spring Boot application context to ensure topics exist before producers and listeners operate.
Building a reliable payments event flow using Spring Kafka involves creating a producer that publishes payment events and a @KafkaListener that processes them. You integrate retry policies and dead-letter topics to handle processing failures gracefully.
You need a dead-letter topic for @KafkaListener message processing to capture messages that fail after exhausting retries. This prevents poison pill messages from blocking your consumer pipeline and allows for later analysis of processing errors.
olehsvyrydovConfigure Spring Kafka producers, consumers, and Dead Letter Topics in Spring Boot applications.
Simon-Copilot-StudioOrganize and automate ML/AI research paper workflows from experiments to submission.
iceflowerConfigure Spring Boot Actuator, Micrometer metrics, OpenTelemetry tracing, and custom health indicators.
lgzarturoImplement domain events and transactional listeners for Spring Boot messaging.
