Kafka Development Practices

Name: Kafka Development Practices
Author: oimiragieo

oimiragieo/agent-studio

36 installs
36 repo stars
Updated July 14, 2026
oimiragieo/agent-studio

Helps with ai & agent building tasks.

About

kafka-development-practices is a Claude Code skill for ai & agent building. It helps solo builders move faster with AI-assisted development.

kafka-development-practices
AI & Agent Building
AI-coding skill

Kafka Development Practices by the numbers

36 all-time installs (skills.sh)
Ranked #8,608 of 16,546 AI & Agent Building skills by installs in the Skillselion catalog
Data as of Aug 4, 2026 (Skillselion catalog sync)

npx skills add https://github.com/oimiragieo/agent-studio --skill kafka-development-practices

Add your badge

Show developers this skill is listed on Skillselion. Paste this into your README.

[![Listed on Skillselion](https://skillselion.com/badge/skills/oimiragieo/agent-studio/kafka-development-practices.svg)](https://skillselion.com/skills/oimiragieo/agent-studio/kafka-development-practices)

Installs	36
repo stars	★ 36
Last updated	July 14, 2026
Repository	oimiragieo/agent-studio ↗

What it does

Helps with ai & agent building tasks.

Files

SKILL.mdMarkdownGitHub ↗

Kafka Development Practices Skill

<identity> You are a coding standards expert specializing in kafka development practices. You help developers write better code by applying established guidelines and best practices. </identity>

Review code for guideline compliance
Suggest improvements based on best practices
Explain why certain patterns are preferred
Help refactor code to meet standards

</capabilities>

<instructions> When reviewing or writing code, apply these guidelines:

All topic names config values (Typesafe Config or pure-config).
Use Format or Codec from the JSON or AVRO or another library that is being used in the project.
Streams logic must be tested with TopologyTestDriver (unit-test) plus an integration test against local Kafka.

</instructions>

<examples> Example usage:

User: "Review this code for kafka development practices compliance"
Agent: [Analyzes code against guidelines and provides specific feedback]

</examples>

Iron Laws

1. ALWAYS set explicit acks=all and min.insync.replicas=2 for production producers — acks=1 (default) loses messages on leader failure before replication; acks=0 provides no delivery guarantee. 2. NEVER commit offsets before processing is complete — committing before processing causes data loss if the consumer crashes between commit and processing; always commit after successful processing. 3. ALWAYS implement idempotent consumers (deduplicate by message key or sequence number) — Kafka's at-least-once delivery guarantees duplicate messages on consumer restarts; processing without deduplication corrupts state. 4. NEVER use auto-offset-reset=earliest in production consumers for existing topics — earliest replays the entire topic history from the beginning on first start; use latest for new consumers on existing topics. 5. ALWAYS set max.poll.interval.ms to a value larger than your maximum processing time — if processing takes longer than max.poll.interval.ms, the consumer is evicted from the group, triggering a rebalance and duplicate processing.

Anti-Patterns

Anti-Pattern	Why It Fails	Correct Approach
`acks=1` for critical data	Leader failure before replication = message loss; no recovery path	Set `acks=all` + `min.insync.replicas=2`; use retries with idempotent producer
Committing offsets before processing	Consumer crash after commit but before processing = message silently dropped	Process completely and durably, then commit; or use transactions for exactly-once
Non-idempotent consumer logic	Rebalances and restarts deliver duplicates; state corrupted without deduplication	Deduplicate by message key/sequence; use idempotent DB writes (upsert by key)
`auto.offset.reset=earliest` on existing topics	Consumer reads entire topic history on first start; may replay millions of events	Set `latest` for new consumer groups on existing topics; use `earliest` only for replay scenarios
Default `max.poll.interval.ms=300s` for slow processors	Slow processing triggers consumer group rebalance mid-batch; duplicate processing	Set `max.poll.interval.ms` > worst-case processing time; reduce batch size if needed

Memory Protocol (MANDATORY)

Before starting:

cat .claude/context/memory/learnings.md

After completing: Record any new patterns or exceptions discovered.

ASSUME INTERRUPTION: Your context may reset. If it's not in memory, it didn't happen.

'use strict';
/**
 * Post-execute hook for kafka-development-practices
 * Auto-generated by enterprise-bundle-scaffolder
 *
 * Records metrics after skill execution.
 */

function postExecute(_context) {
  // Record execution metrics
  return { ok: true, skill: 'kafka-development-practices' };
}

module.exports = { postExecute };

'use strict';
/**
 * Pre-execute hook for kafka-development-practices
 * Auto-generated by enterprise-bundle-scaffolder
 *
 * Validates inputs before skill execution.
 */

function preExecute(context) {
  // Validate skill invocation context
  if (!context || typeof context !== 'object') {
    return { allow: true, message: 'kafka-development-practices: no context to validate' };
  }
  return { allow: true };
}

module.exports = { preExecute };

{
  "$schema": "http://json-schema.org/draft-07/schema#",
  "title": "kafka-development-practicesInput",
  "description": "Input schema for Applies general coding standards and best practices for Kafka development with Scala.",
  "type": "object",
  "additionalProperties": true,
  "properties": {
    "target": {
      "type": "string",
      "description": "Target file or path for the skill to operate on"
    },
    "options": {
      "type": "object",
      "description": "Additional options for skill execution",
      "additionalProperties": true
    }
  }
}

{
  "$schema": "http://json-schema.org/draft-07/schema#",
  "title": "kafka-development-practicesOutput",
  "type": "object",
  "additionalProperties": true,
  "properties": {
    "ok": {
      "type": "boolean"
    },
    "summary": {
      "type": "string"
    }
  }
}

#!/usr/bin/env node
'use strict';
/**
 * kafka-development-practices - Enterprise Skill Script
 * Auto-generated by enterprise-bundle-scaffolder
 */

const fs = require('fs');
const path = require('path');

// Parse arguments
const args = process.argv.slice(2);
const options = {};
for (let i = 0; i < args.length; i++) {
  if (args[i].startsWith('--')) {
    const key = args[i].slice(2);
    const value = args[i + 1] && !args[i + 1].startsWith('--') ? args[++i] : true;
    options[key] = value;
  }
}

if (options.help) {
  console.log(`
kafka-development-practices - Enterprise Skill

Usage:
  node main.cjs --check <file>    Check a file against guidelines
  node main.cjs --list            List all guidelines
  node main.cjs --help            Show this help

Description:
  Applies general coding standards and best practices for Kafka development with Scala.
`);
  process.exit(0);
}

if (options.list) {
  console.log('Guidelines for kafka-development-practices:');
  console.log('See SKILL.md for full guidelines');
  process.exit(0);
}

console.log('kafka-development-practices skill loaded. Use with Claude for code review.');