← ClaudeAtlas

kora-kafka-consumerlisted

Kora Kafka consumers — @KafkaListener on a @Component method (KafkaModule), commit strategies, @Json deserialization, error handling, batch. Use when consuming Kafka messages or configuring kafka.consumer.
kora-projects/kora-skills · ★ 1 · Code & Development · score 72
Install: claude install-skill kora-projects/kora-skills
# Kora Kafka Consumer Skill > **Kora sub-skill — obey the [kora-v1 meta rules](../../SKILL.md) on every task:** **R0** ensure `.kora-agent/` docs+examples are cloned · **R1** read this sub-skill before writing code · **R2** Kora APIs only — no Spring/Micronaut/Quarkus, no invented annotations or config keys · **R3** journal any incorrect Kora usage. Add comments/Javadoc only if asked. **Languages:** Java, Kotlin | **Build:** Gradle > **Level 1** — [Quick Start](#quick-start) | **Level 2** — [Signatures](#method-signatures) | **Level 3** — [Errors & Offset](#error-handling) | **Level 4** — [Batch & Rebalance](#batch-processing) **References:** [Consumer config](references/kafka-consumer-reference.md) | [Listener signatures](references/kafka-listener-reference.md) | [Strategies](references/kafka-strategies-reference.md) | [Serialization](references/kafka-serialization-reference.md) | [Errors](references/kafka-error-handling-reference.md) | [Offset](references/kafka-offset-reference.md) | [Batch](references/kafka-batch-reference.md) | [Rebalance](references/kafka-rebalance-reference.md) | [Telemetry](references/kafka-telemetry-reference.md) | [Transactions (producer)](references/kafka-transactions-reference.md) | [Testing](references/kafka-testing-reference.md) --- ## Quick Start **1. Dependencies** (Kora artifacts inherit their version from the `kora-parent` BOM — never pin them individually): ```groovy dependencies { koraBom platform("ru.tinkoff.kora:kora-parent:1.2