Kafka AI Prompts
24 free, production-ready Kafka AI prompts — copy-paste ready for ChatGPT, Claude, or Cursor. Every prompt ships with fill-in placeholders, a worked example, and production-safety notes, so you get a usable answer on the first try.
- Kafka Advanced
Kafka Client Quota and Throttling Design Prompt
Design produce, fetch, and request-percentage quotas per user/client-id so one noisy tenant cannot saturate broker network or CPU and starve others on a shared cluster.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Connect Dead Letter Queue and Error Handling Design Prompt
Design connector-level error tolerance, dead-letter-queue routing, and retry/backoff for Kafka Connect so a single poison record or transient sink failure never silently drops data or stalls the connector.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Cost and Storage Footprint Optimization Prompt
Review a Kafka cluster's storage, replication, and retention footprint to cut disk and inter-broker/cross-AZ network cost without weakening durability guarantees.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Cruise Control Self-Balancing Setup Prompt
Configure LinkedIn Cruise Control goals, capacity model, and anomaly detection to keep partition load, disk, and leadership balanced automatically without manual reassignment JSON.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Log Retention and Compaction Policy Audit Prompt
Audit topic-level retention and compaction settings across a cluster to stop unbounded disk growth, avoid premature data loss, and confirm compacted topics actually compact.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka JMX and Prometheus Alerting Runbook Prompt
Build a focused set of Kafka broker and client alerts from JMX/Prometheus metrics that catch under-replication, request saturation, and lag early without drowning on-call in noise.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Multi-Tenancy and Topic Naming Governance Prompt
Define a topic naming convention, ACL model, and quota boundaries for a shared multi-tenant Kafka cluster so tenants are isolated, discoverable, and enforceable by prefix.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Rolling Version Upgrade Plan Prompt
Plan a zero-downtime rolling upgrade of a Kafka cluster across versions, sequencing inter.broker.protocol.version and log.message.format.version bumps so clients never break mid-upgrade.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Schema Registry Compatibility Governance Prompt
Design and enforce a schema evolution policy in Confluent/Apicurio Schema Registry so producers and consumers stay compatible through changes without breaking downstream consumers.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Broker Rolling Restart Runbook Prompt
Plan and sequence a safe rolling restart or config change across a Kafka cluster without dropping below min ISR or triggering unnecessary leader elections.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Consumer Offset Reset and Replay Plan Prompt
Plan a safe consumer-group offset reset or message replay — by timestamp, offset, or shift — without double-processing, skipping data, or corrupting downstream state.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Tiered Storage Configuration Review Prompt
Design or troubleshoot Kafka tiered storage (KIP-405) so hot data stays on local disk while older segments offload to object storage without breaking retention, fetches, or recovery.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Connect Pipeline Debugging & Tuning Prompt
Diagnose a failing or lagging Kafka Connect pipeline — dead or restarting tasks, DLQ growth, offset stalls, and rebalance churn — then prescribe connector, converter, and worker tuning that is safe to roll out.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka MirrorMaker 2 Multi-Region DR Design Prompt
Design a MirrorMaker 2 cross-region replication and disaster-recovery topology — active/passive vs. active/active, offset translation, topic/ACL sync, and failover runbook — with the RPO/RTO trade-offs made explicit.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Streams Stateful Topology Tuning Prompt
Analyze a Kafka Streams application with state stores — RocksDB memory pressure, slow restore/rebalance, changelog bloat, and repartition-driven lag — and prescribe topology, standby, and RocksDB tuning that preserves correctness.
- Claude
- ChatGPT
- Cursor
Open prompt - Kafka Advanced
Kafka Cluster Sizing & Capacity Planning Prompt
Size a Kafka cluster end to end — broker count, partition counts, retention, disk, memory, and network — for a target throughput, with headroom for spikes and broker failure.
- Claude
- ChatGPT
Open prompt - Kafka Intermediate
Kafka Consumer Lag Investigation Prompt
Investigate and reduce growing consumer lag by isolating the root cause — slow processing, partition skew, GC pauses, or broker-side bottlenecks — then prescribe targeted fixes.
- Claude
- ChatGPT
Open prompt - Kafka Advanced
Kafka Consumer Rebalance Storm Triage Prompt
Diagnose frequent or looping consumer-group rebalances by working through session, heartbeat, and poll timeouts, static membership, and the rebalance protocol in use.
- Claude
- ChatGPT
Open prompt - Kafka Advanced
Kafka Exactly-Once Semantics Design Prompt
Design exactly-once processing across a produce-process-consume pipeline using the idempotent producer and transactions, with honest guidance on where EOS holds and where it does not.
- Claude
- ChatGPT
Open prompt - Kafka Advanced
Kafka Partition Reassignment & Broker Decommission Plan Prompt
Plan a safe partition reassignment or broker decommission using throttled data movement, staged batches, and verification, minimizing impact on live traffic.
- Claude
- ChatGPT
Open prompt - Kafka Intermediate
Kafka Producer Throughput & Latency Tuning Prompt
Tune Kafka producer batching, compression, acks, linger, and idempotence to hit a throughput or latency target while keeping the durability guarantees you actually need.
- Claude
- ChatGPT
Open prompt - Kafka Advanced
Kafka TLS, SASL & ACL Security Hardening Prompt
Harden a Kafka cluster end to end — TLS encryption, SASL authentication, and least-privilege ACLs with per-principal scoping — and produce a phased rollout that avoids locking out clients.
- Claude
- ChatGPT
Open prompt - Kafka Intermediate
Kafka Topic Design & Partitioning Strategy Prompt
Design a Kafka topic from first principles — partition count, keying, replication factor, min.insync.replicas, and retention vs. compaction — to match ordering, scale, and durability needs.
- Claude
- ChatGPT
Open prompt - Kafka Advanced
Kafka ZooKeeper to KRaft Migration Plan Prompt
Plan a staged migration from ZooKeeper-based Kafka to KRaft mode with version prerequisites, controller quorum design, rollback checkpoints, and validation at each phase.
- Claude
- ChatGPT
Open prompt
About these Kafka AI prompts
This is a free, curated collection of Kafka AI prompts for DevOps and platform engineers — prompt templates that turn Claude, ChatGPT, or Cursor into a focused Kafka assistant. Instead of re-explaining your setup every time, each prompt has fill-in placeholders, a realistic worked example, and explicit safety and back-out notes, so it's safe to use against production Kafka.
Browse all 24 above, or explore the wider Kafka prompts and troubleshooting guides, the full DevOps AI prompt library, and run or compare any prompt live in the Prompt Workspace. Hit a production issue instead? Try the free Incident Assistant.