A read-only tool for inspecting Apache Kafka, a system that moves streams of messages between applications.

Use it to list and inspect topics, consumer groups, partitions, brokers, configurations, and a limited number of messages. Kafka command-line tools must be installed.

It avoids relying on several Kafka command-line tools or manually checking cluster state and message positions.

kafka — Skill for Claude Code and Codex by fisker086/AIOps

Install

Getting it into your agent

One page per mod, every tool's command on it. A separate URL per tool would split the same page into five that compete with each other.

Any agent

npx skills add fisker086/AIOps --skill kafka

Clone the repo

git clone --depth 1 https://github.com/fisker086/AIOps

Made for: Claude Code, Codex.

Wrote 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.

README.md

[![agentmods](https://agentmods.dev/badge/skills/fisker086/aiops/kafka/github.svg)](https://agentmods.dev/skills/fisker086/aiops/kafka)

Your own site

<a href="https://agentmods.dev/skills/fisker086/aiops/kafka"><img src="https://agentmods.dev/badge/skills/fisker086/aiops/kafka/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.

Your own site · 80×15

<a href="https://agentmods.dev/skills/fisker086/aiops/kafka"><img src="https://agentmods.dev/badge/skills/fisker086/aiops/kafka.svg" alt="Reviewed on agentmods" width="80" height="20"></a>

Per session 13 Skills are progressive disclosure: only the name and description are preloaded; the body loads when the skill is used.

When invoked 271 The whole file, excluding the scripts and references it only reads on demand.

Security scan A 0 findings. A grade says what 26 rules found in the file — not that it is safe.

Origin original No closer match found in the catalogue.

Token cost

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.00013	$0.00271
Opus 5.5	$0.00005	$0.00108
Sonnet 5.5	$0.00003	$0.00054
Haiku 4.5	$0.00001	$0.00027

Measured 2mo ago against content hash 94572e63f3b6, method: parsed. Prices are Anthropic first-party input rates as of 2026-10-07, from the pricing page.

Security

Grade A, and why

kafka 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 2mo 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.

skills/kafka/SKILL.md · 28 lines

What it actually says

Kafka Skill

Provides read-only Kafka cluster operations via local CLI:

List and describe topics (partitions, replicas, ISR)
List consumer groups and their offsets
Get messages from topics (limited)
Describe cluster and broker info
Get topic configurations

Use builtin_kafka tool with fields:

operation: one of "list_topics", "describe_topic", "list_groups", "describe_group", "get_messages", "get_config", "broker_info"
topic: topic name (required for describe_topic/get_messages/get_config)
group: consumer group name (required for describe_group)
bootstrap_server: Kafka bootstrap server (default: "localhost:9092")
partition: partition number (for get_messages, default: 0)
offset: offset to start from (for get_messages, default: -1 meaning latest)
limit: max messages to fetch (default: 10)

Note: Requires Kafka CLI tools (kafka-topics, kafka-consumer-groups, kafka-console-consumer) installed and accessible in PATH. All operations are read-only.

Changes

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.

2mo ago First seen · 28 lines · 13 tokens per session scan A 94572e63f3b6

Subscribe to this mod's changes

kafka is a skill published in the GitHub repository fisker086/AIOps (22 stars, last pushed 4mo ago), licensed Apache-2.0. It adds 13 tokens to every session and 271 once invoked, about $0.0001 per session on Opus 5.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-30.

Backend and APIs

kafka next to 6 skills from other repositories
Mod	Type	Stars	Last push	Licence	Scan	Tokens	Works with
kafkafisker086/AIOps	Skill	22	4mo ago	Apache-2.0	A	13	Claude Code, Codex
mem0-oss-to-platformmem0ai/mem0	Skill	68k	2d ago	Apache-2.0	A	217	Claude Code, Codex
azure-mgmt-botservice-dotnetmicrosoft/skills	Skill	3.2k	yesterday	MIT	A	78	Claude Code
fastapi-router-pymicrosoft/skills	Skill	3.2k	yesterday	MIT	A	46	Claude Code
dev-runtimelangwatch/langwatch	Skill	5.0k	yesterday	Apache-2.0	A	172	Claude Code
api-designericrisco/rsc-harness	Skill	503	2d ago	MIT	A	105	Claude Code, Codex
migrate-segw-to-raparc-mcp/arc-1	Skill	252	yesterday	MIT	A	106	Claude Code