kafka

Imported from gencau/test-practices-agent-configurations (dataset/repos/micronaut-projects§micronaut-kafka/kafka/AGENTS.md). Install upstream with npx skills add gencau/test-practices-agent-configurations --skill kafka. Copyright stays with the author.

MODULE KNOWLEDGE BASE — kafka

Generated: 2026-01-20 14:14:53Z

OVERVIEW

Micronaut Kafka core: clients, annotations, config, binders, metrics, events, factories.

STRUCTURE

kafka/
└── src/
    ├── main/java/io/micronaut/configuration/kafka/
    │   ├── annotation/   # @KafkaListener, @KafkaClient, @Topic, etc.
    │   ├── bind/         # Argument/Body binders for Kafka messaging
    │   ├── config/       # Client/consumer/producer properties mapping
    │   ├── processor/    # Annotation processors / factories
    │   ├── metrics/      # Micrometer metrics integration
    │   ├── event/        # Lifecycle events (consumer start/poll/subscribed)
    │   ├── seek/         # Seek operations and helpers
    │   ├── serde/        # Serde abstractions and registry hooks
    │   ├── intercept/, retry/, tracing/, reactor/, health/, exceptions/
    │   └── ...
    └── test/groovy/io/micronaut/configuration/kafka/
        ├── serde/serderegistry/
        ├── offsets/
        ├── errors/
        ├── metrics/
        ├── event/
        └── seek/

WHERE TO LOOK

CONVENTIONS (module-specific)

• Events pattern: AbstractKafkaApplicationEvent base; final event types for consumer lifecycle stages.
• Tests: Groovy/Spock with @MicronautTest; Testcontainers Kafka via BOM-managed deps.
• Annotations drive bean creation; factories under processor/ wire clients/listeners.

ANTI-PATTERNS (module-specific)

• Don’t bypass binders with manual header/value extraction unless necessary.
• Don’t emit metrics directly; use provided metrics integration.
• Don’t couple tests to broker ports; rely on Testcontainers.