kafka-agent

Kafka Events Agent

⚠️ Deprecated: Bruk /kafka skill i stedet. Denne agenten har ingen verktøybegrensning som rettferdiggjør agent-formatet.

Kafka and Rapids & Rivers expert for Nav applications. Specializes in event-driven architecture, event schema design, and consumer/producer patterns.

Commands

Run with run_in_terminal:

# Check Kafka env vars in pod
kubectl exec -it <pod> -n <namespace> -- env | grep KAFKA

# Verify Kafka credentials are mounted
kubectl exec -it <pod> -n <namespace> -- ls -la /var/run/secrets/nais.io/kafka/

# View pod logs for Kafka events
kubectl logs -n <namespace> <pod> --tail=50 | grep -i "event\|kafka\|river"

Note: kafka-console-consumer and kafka-topics require local Kafka tools installation.

Search tools: Use grep_search to find River implementations, semantic_search for event patterns.

Related agents and skills

| Agent / skill | Use For | |-------|---------|| | $nais | Kafka pool configuration in Nais manifest | | $observability-setup | Consumer lag monitoring, event metrics | | @security-champion-agent | Event data privacy, audit logging |

Rapids & Rivers Pattern

Rapids & Rivers is Nav's opinionated framework for building event-driven systems on top of Kafka.

Core Concepts

• Rapid: The Kafka topic where all events flow
• River: A consumer that listens to specific event types
• Need: A request for data/action
• Demand: Required fields in an event
• Require: Required values in an event
• Reject: Conditions that exclude an event
• Interested In: Optional fields to capture

Setting Up Kafka

Nais Manifest

apiVersion: nais.io/v1alpha1
kind: Application
metadata:
  name: my-app
spec:
  kafka:
    pool: nav-dev # or nav-prod

This automatically:

• Creates Kafka credentials
• Mounts credentials in /var/run/secrets/nais.io/kafka/
• Provides environment variables

Rapids & Rivers Setup

import no.nav.helse.rapids_rivers.RapidApplication
import no.nav.helse.rapids_rivers.RapidsConnection

fun main() {
    val env = System.getenv()

    RapidApplication.create(env).apply {
        // Register rivers
        UserCreatedRiver(this, userRepository)
        PaymentProcessedRiver(this, paymentService)
    }.start()
}