skills.rest
cavanli
cavanliCOMMUNITY
Explore all skills by this author →
GitHub

KafkaOps

Automate Kafka cluster administration, topic governance, and fault recovery workflows.

Updated Aug 23, 2026
Search Tags:#performance#streaming#kafka#cluster-management#fault-tolerance#kafka-ops
One-click install
npx skills add https://github.com/cavanli/aiops --skill kafkaops
Or copy as Structured Prompt for Agent▼
Please help me install this Agent Skill.
Skill: KafkaOps
Source: https://github.com/cavanli/aiops/tree/main/skills/kafka-ops
Command: npx skills add https://github.com/cavanli/aiops --skill kafkaops

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Kafka ops tasks such as cluster health checks, topic governance, and fault recovery are time-consuming and error-prone without automation.

Core Features & Use Cases

  • Cluster management: manage brokers, topics, partitions, and rebalance tasks, with health checks and retention reviews.
  • Performance tuning & governance: monitor lag, optimize producer/consumer configs, and enforce operational policies across clusters.
  • Fault recovery: detect partition replication issues, trigger recovery workflows, and integrate with MCP to provide contextual insights.

Quick Start

Immediately inspect and stabilize a Kafka deployment by listing topics, describing a topic, and inspecting consumer group status.

Frequently Asked Questions about KafkaOps

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I automate Kafka cluster management and health checks?▼

Automate Kafka cluster management by running reusable admin workflows that perform broker health checks, retention reviews, and partition rebalancing across on-prem and cloud deployments to ensure reliable operations.

What is the best way to monitor consumer lag and optimize Kafka performance?▼

Monitor consumer lag and optimize Kafka performance by enforcing operational policies, tuning producer and consumer configurations, and reviewing topic governance to maintain streaming throughput.

How do I recover from Kafka partition replication failures?▼

Recover from Kafka partition replication failures by detecting issues, triggering automated fault recovery workflows, and integrating with MCP to provide contextual insights for auditable resolution.

Does this approach support topic governance for both on-prem and cloud deployments?▼

Topic governance is supported across on-prem and cloud deployments, allowing you to manage brokers, topics, and partitions while enforcing operational policies for consistent cluster administration.

Why do I need automated workflows for Kafka fault tolerance?▼

Automated workflows are needed for Kafka fault tolerance because manual cluster health checks and recovery are time-consuming and error-prone without safe, reusable admin processes providing clear success and failure signaling.

Related Skills

Explore More Data & Analytics Skills→
hoangnh2412hoangnh2412
12

healthcheck-dotnet-kafka

Configure Kafka connectivity health checks for ASP.NET Core readiness probes.

Community
Basic
supersuit-techsupersuit-tech
4

fix-ci

Trigger GitHub Actions CI and audit workflows, collect failure logs, and iterate until both pass.

Official
Intermediate
AltinityAltinity
16

altinity-expert-clickhouse-kafka

Diagnose ClickHouse Kafka engine health and consumer performance across clusters.

Official
Advanced
OmniNode-aiOmniNode-ai
3

reconcile-artifacts

Publish artifact reconciliation commands to the onex.cmd.artifact.reconcile.v1 Kafka topic.

Official
Advanced