kafka-patterns
Topic design, partition strategies, consumer group patterns, exactly-once processing, and dead letter queue handling.
npx skills add vibeeval/vibecosystem --skill kafka-patterns --agent claude-code
Same command for any agent — swap --agent for codex, cursor, copilot.
Weekly change comes from our own snapshots, not the repository page — it measures attention, not adoption.
# Kafka Patterns Event streaming patterns for Apache Kafka in distributed systems. ## Topic Design ```yaml # Topic naming convention: <domain>.<entity>.<event-type> # Examples: # orders.order.created # payments.payment.completed # inventory.stock.updated # Topic configuration topics: orders.order.created: partitions: 12 # Match expected consumer parallelism replication-factor: 3 # Survive 2 broker failures retention.ms: 604800000 # 7 days cleanup.policy: delete orders.order.changelog: partitions: 12 replication-factor: 3 retention.ms: -1 # Infinite retention (compacted) cleanup.policy: compact # Keep latest value per key min.compaction.lag.ms: 3600000 # 1h before compacting ``` ## Producer Patterns ```typescript import { Kafka, Partitioners, CompressionTypes } from 'kafkajs' const kafka = new Kafka({ clientId: 'order-service', brokers: process.env.KAFKA_BROKERS!.split(','), }) const producer = kafka.producer({ idempotent: true, // Exactly-once producer maxInFlightRequests: 5, // Max parallel requests createPartitioner: Partitioners.DefaultPartitioner, }) await producer.connect() // Key-based partitioning: same key always goes to same partition (ordering) async function publishOrder
- Topic Design
- Producer Patterns
- Consumer Group Patterns
- Dead Letter Queue (DLQ)
- Partition Strategy
- Checklist
- Anti-Patterns
What does the kafka-patterns skill do?
Topic design, partition strategies, consumer group patterns, exactly-once processing, and dead letter queue handling.
How do I install it?
Run `npx skills add vibeeval/vibecosystem --skill kafka-patterns --agent claude-code` — it drops the skill into your project so the agent can pick it up. Swap the --agent value for codex, cursor or copilot if you use one of those.
Where does this skill come from?
From vibeeval/vibecosystem, a repository with 521 stars. We read it straight from the repository tree rather than a submitted listing, so what you see here is what is actually published.
Is a popular skill a good skill?
Not necessarily. Stars measure attention, not adoption — a repository can trend for a week and be abandoned. That is why we show the weekly change from our own snapshots next to the total, instead of a single flattering number.