Designs Rap-and-Rivers Kafka integrations for Kotlin/Nais services with TestRapid validation.
npx skills add https://github.com/navikt/copilot --skill kafka-navikt
Please help me install this Agent Skill. Skill: kafka Source: https://github.com/navikt/copilot/tree/main/.github/skills/kafka Command: npx skills add https://github.com/navikt/copilot --skill kafka-navikt
It solves the challenge of designing and implementing reliable, event-driven Kafka integrations in Nav-style Kotlin services, including topic setup, event schema design, and safe consumer/producer patterns.
spec.kafka so credentials and environment variables are mounted automatically.Use the kafka skill to set up Rapids & Rivers rivers in a Nais Kotlin service and generate/validate Kafka events using the required event metadata and schema rules.
High-intent search queries and answers about installing and using this skill.
Kafka connectivity for a Nais application is configured through the Nais manifest using spec.kafka, which automatically mounts the necessary credentials and environment variables for your service.
Event-driven consumers are built using River listeners with preconditions for event type filtering, validations for schema correctness, and clean error handling to process Kafka events reliably.
A Kafka event schema must include standard metadata like event name, @id for idempotency, created_at, produced_by, and optional correlation id to ensure proper event governance and versioning.
Kafka event systems are tested and troubleshot using TestRapid to validate behavior, allowing you to diagnose connectivity issues, consumer lag, and contract violations within event-driven services.
This event-driven Kafka approach applies to Nais-backed Kotlin/JVM services, providing topic configuration, River-based event handling, and event versioning for reliable stream processing.
Error handling in Rapids & Rivers consumers involves applying River validate rules with appropriate error handling and DLQ/retry guidance to manage event processing failures safely.
ClankerGuruConfigure and enforce Kotlin static analysis with detekt in Gradle projects.
curiositechDesigns Kafka-based ordering pipelines with transactional outbox, idempotent consumers, and DLQ policies for backend microservices architectures.
ccfDesign event stores with schemas, versioning, and append-only streams.
ancolemanBuild event streaming pipelines with Kafka, Pulsar, Redpanda, and RabbitMQ.