kafka

Manage Kafka clusters, topics, and messages with CLI tools.

24|11|Updated Feb 19, 2026
One-click install
npx skills add https://github.com/clawdata/clawdata --skill kafka-clawdata
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: kafka
Source: https://github.com/clawdata/clawdata/tree/main/skills/kafka
Command: npx skills add https://github.com/clawdata/clawdata --skill kafka-clawdata

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Kafka cluster management can be error-prone and manual; this Skill provides a CLI-driven toolkit to view, create, describe, produce, and consume Kafka topics, messages, consumer groups, and cluster configurations.

Core Features & Use Cases

  • List, describe, create, delete, and alter topics
  • Produce and consume messages via the Kafka CLI
  • Inspect consumer group offsets and lag
  • Monitor cluster health and basic configurations
  • Use Case: You need to quickly verify topic existence and simulate a producer to validate a consumer pipeline in a dev environment.

Quick Start

Ask me to list topics on your cluster to verify connectivity.

Frequently Asked Questions about kafka

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

FAQPage Schema
How do I manage Kafka topics and inspect consumer groups via CLI?

Manage Kafka topics and inspect consumer groups by running CLI utilities like kafka-topics to create, describe, or alter topics, and kafka-console-consumer to monitor offsets and lag across your cluster.

Can I produce and consume messages to test a Kafka pipeline in a dev environment?

Produce and consume messages to test a Kafka pipeline in a dev environment by using kafka-console-producer and kafka-console-consumer CLI tools to simulate message flow and validate consumer connectivity.

What do I need to connect to a Kafka cluster and create topics?

To connect to a Kafka cluster and create topics, you need a reachable bootstrap server, adequate cluster permissions, and access to standard Kafka CLI utilities to execute topic creation and configuration commands.

Why does my Kafka consumer group show lag when checking cluster health?

Kafka consumer group lag occurs when consumers process messages slower than producers generate them; inspect consumer group offsets and lag using CLI tools to monitor cluster health and identify processing bottlenecks.

What is the best way to verify topic existence before producing messages?

Verify topic existence before producing messages by listing and describing topics on your cluster via the kafka-topics CLI utility, which confirms connectivity and validates that the target topic is available.

Are there limitations when using Kafka CLI tools for cluster management in production?

Kafka CLI tools for cluster management in production are limited by manual execution, requiring adequate permissions and a reachable bootstrap server, making them less suitable for automated or large-scale operational workflows.