Stats
Actions
Tags
Apply when creating, modifying, or reviewing any file that consumes from Kafka (classes annotated with @KafkaListener or with names containing in Consumer/Listener)
How this skill is triggered — by the user, by Claude, or both
Slash command
/kotlin-building-blocks:implementing-kafka-consumersThe summary Claude sees in its skill listing — used to decide when to auto-load this skill
Message consumers listen to message queues (Kafka, RabbitMQ) and trigger application services. They translate external messages into application service calls.
Message consumers listen to message queues (Kafka, RabbitMQ) and trigger application services. They translate external messages into application service calls.
DO:
<Topic><StreamSystem>Consumer, e.g., OrdersKafkaConsumerDON'T:
@KafkaListener annotation@EnableKafka is enabledKafkaConfig class for separate configurationDefaultErrorHandler with exponential backoff is configured through ConcurrentKafkaListenerContainerFactoryDeadLetterPublishingRecoverer is configuredPlease use always these examples as reference: examples.md
npx claudepluginhub allousas/claude-code-plugins --plugin kotlin-building-blocksConfigures Spring Boot's Kafka starter via application.properties/yml or a generated KafkaConfiguration class. Useful when adding Kafka producer/consumer beans or before wiring KafkaTemplate and @KafkaListener.
Guides Kafka topic design (partitions, replication), KafkaJS idempotent producers/consumers, consumer lag monitoring, exactly-once semantics, schema registry, compacted topics, and DLQ patterns. Use for reliable streaming implementations.
Produces and consumes Kafka messages with partitioning, consumer groups, offset management, and transactional support using KafkaJS.