Getting it into your agent
It runs from inside its repository, so the clone comes first — what it calls does not travel with the file alone.
git clone --depth 1 https://github.com/kora-projects/kora-skillsnpx agentmods add skills/kora-projects/kora-skills/kora-kafka-consumerWrote this? Show the measurements
A badge with what this costs and how it scanned, read live from this page, so it follows the numbers instead of freezing them. Markdown for a README, HTML for a documentation site or a project page.
[](https://agentmods.dev/skills/kora-projects/kora-skills/kora-kafka-consumer)<a href="https://agentmods.dev/skills/kora-projects/kora-skills/kora-kafka-consumer"><img src="https://agentmods.dev/badge/skills/kora-projects/kora-skills/kora-kafka-consumer/github.svg" alt="Measured on agentmods" height="20"></a>Or the 80×15 button, for a site that already has a row of RSS and ATOM ones. Only the verdict fits; the numbers stay here.
<a href="https://agentmods.dev/skills/kora-projects/kora-skills/kora-kafka-consumer"><img src="https://agentmods.dev/badge/skills/kora-projects/kora-skills/kora-kafka-consumer.svg" alt="Reviewed on agentmods" width="80" height="20"></a>What it costs to keep this loaded
Counted locally with the o200k_base tokenizer, which is exact for GPT models; Claude uses its own tokenizer and its counts differ. Treat this as one consistent yardstick across the catalogue rather than a bill. Prices are per million input tokens.
| Model | Per session | Once invoked |
|---|---|---|
| Fable 5.1 | $0.00047 | $0.02415 |
| Opus 5 | $0.00023 | $0.01208 |
| Sonnet 5 | $0.00009 | $0.00483 |
| Haiku 4.5 | $0.00005 | $0.00242 |
Grade A, and why
kora-kafka-consumer scanned grade A with 0 findings against 26 rules in 11 categories — prompt injection, anti-refusal, data exfiltration, privilege escalation, supply chain, agent snooping, system-prompt leakage, SSRF and excessive agency — measured 11d ago.
A static scan of the body, not an audit. Every finding is printed with the line that produced it so you can judge whether it matters here. A mod is markdown that instructs an agent; that is exactly why what it instructs is worth reading.
Nothing flagged
None of the 26 patterns this scan looks for appear in this file: no shell pipes, no recursive deletes, no credential paths, no hidden text, no instruction-override or anti-refusal phrasing, no agent-config snooping. That is not a guarantee, it is the absence of the things that are checkable.
How it starts
The opening of the file, as written. The whole thing — 286 lines — stays where its author put it; the contents beside it link to each section on GitHub.
Kora Kafka Consumer Skill
Kora sub-skill — obey the kora-v1 meta rules 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 | Level 2 — Signatures | Level 3 — Errors & Offset | Level 4 — Batch & Rebalance
References: Consumer config | Listener signatures | Strategies | Serialization | Errors | Offset | Batch | Rebalance | Telemetry | Transactions (producer) | Testing
Quick Start
1. Dependencies (Kora artifacts inherit their version from the kora-parent BOM — never pin them individually):
dependencies {
koraBom platform("ru.tinkoff.kora:kora-parent:1.2.19")
annotationProcessor "ru.tinkoff.kora:annotation-processors"
implementation "ru.tinkoff.kora:kafka"
implementation "ru.tinkoff.kora:json-module"
implementation "ru.tinkoff.kora:config-hocon"
implementation "ru.tinkoff.kora:logging-logback"
}
2. Application Module (a @KoraApp interface extends each module — interfaces never use implements):
@KoraApp
public interface Application extends KafkaModule, JsonModule, HoconConfigModule, LogbackModule {
static void main(String[] args) {
KoraApplication.run(ApplicationGraph::graph);
}
}
What ships with it
35 files beside SKILL.md in the same directory: the scripts, references and assets a skill reads on demand. Not counted in the per-session cost; read them before you install if any of them is executable.
- assets/application.conf.template 7.6 KB
- assets/Application.java.template 567 B
- assets/Application.kt.template 592 B
- assets/build.gradle.kts.template 2.0 KB
- assets/build.gradle.template 1.6 KB
- assets/ConsumerListener.java.template 12 KB
- assets/ConsumerListener.kt.template 8.3 KB
- assets/ConsumerListenerTests.java.template 16 KB
- assets/ConsumerListenerTests.kt.template 11 KB
- assets/JsonMessageListener.java.template 9.1 KB
- assets/JsonMessageListener.kt.template 4.0 KB
- assets/JsonMessagePublisher.java.template 907 B
- assets/JsonMessagePublisher.kt.template 905 B
- assets/MessagePublisher.java.template 1.4 KB
- assets/MessagePublisher.kt.template 1.4 KB
- assets/MessagePublisherTests.java.template 5.1 KB
- assets/MessagePublisherTests.kt.template 4.8 KB
- assets/TransactionalPublisher.java.template 1.9 KB
- assets/TransactionalPublisher.kt.template 1.6 KB
- evals/evals.json 7.0 KB
- evals/kafka-consumer-eval.md 11 KB
- references/kafka-batch-reference.md 8.0 KB
- references/kafka-consumer-reference.md 9.3 KB
- references/kafka-error-handling-reference.md 12 KB
- references/kafka-listener-reference.md 5.3 KB
- references/kafka-offset-reference.md 7.6 KB
- references/kafka-rebalance-reference.md 13 KB
- references/kafka-serialization-reference.md 8.0 KB
- references/kafka-strategies-reference.md 5.2 KB
- references/kafka-telemetry-reference.md 8.7 KB
- references/kafka-testing-reference.md 14 KB
- references/kafka-transactions-reference.md 5.8 KB
- scripts/generate_consumer.py 29 KB runs code
- scripts/generate_producer.py 13 KB runs code
- scripts/validate_config.py 5.2 KB runs code
What this file has done since we first saw it
Hashed on every crawl. A supply-chain change to an agent config is a question of when, not whether, so the history is kept rather than the latest state alone.
- 11d ago First seen · 286 lines · 47 tokens per session scan A d56dd78cbfa7
kora-kafka-consumer is a skill published in the GitHub repository kora-projects/kora-skills (1 stars, last pushed 11d ago), licensed Apache-2.0. It adds 47 tokens to every session and 2,415 once invoked, about $0.0002 per session on Opus 5. A static security scan graded it A with 0 findings. No closer match exists in the catalogue, so it is treated as the original; first seen 2026-08-31.
Other skills, from other repositories
horse-database-pooling
Guide for setting up thread-safe database connection pooling (FireDAC / UniDAC) in multithreaded Horse applications.
horse-mvc-architecture
Guide for structuring corporate Horse applications using Clean MVC (Model-View-Controller) principles and decoupling HTTP layers from business logic.
horse-request-response
Guide to interacting with THorseRequest (body, query, params, headers) and THorseResponse (Send, Status, ContentType).
horse-dependency-injection
Guide for managing request-scoped contextual services and IoC (dependency injection) in Delphi and Lazarus.
horse-performance-tuning
Guide for optimizing performance, tuning memory alocations, handling large payloads, and adjusting provider execution pipelines.
horse-ssl-tls
Guide to enabling SSL/TLS, configuring HTTPS, handling certificates, and securing transport layers.