Ready to supercharge your AI agents?

Install any skill in seconds. Free to start, no credit card required.

Kafka Producer Consumer · dicklesworthstone | DecimalAI

dicklesworthstone/kafka-producer-consumer

NewSkillScoreMaintained

Manage kafka producer consumer operations. Auto-activating skill for Backend Development. Triggers on: kafka producer consumer, kafka producer consumer Part of the Backend Development skill category. Use when working with kafka producer consumer functionality. Trigger with phrases like "kafka producer consumer", "kafka consumer", "kafka".

by dicklesworthstone

Links this skill to your agents and keeps it current with the author’s updates.

Automatic

Coding pack

1 · One-time — install the CLI (docs ↗)

pip install decimalai

2 · Get the skill — writes .claude/skills/dicklesworthstone-kafka-producer-consumer/SKILL.md

decimalai skills pull dicklesworthstone-kafka-producer-consumer --out .claude/skills/

No CLI? Get the same file — curl · raw file

curl -fsSL --create-dirs -o .claude/skills/dicklesworthstone-kafka-producer-consumer/SKILL.md https://app.decimal.ai/s/dicklesworthstone-kafka-producer-consumer/SKILL.md

Raw file: /s/dicklesworthstone-kafka-producer-consumer/SKILL.md ↗ · machine-readable summary at /s/dicklesworthstone-kafka-producer-consumer.json ↗

In productionGlobal

how this skill behaves on real traffic · last 30 days

No production data for this skill yet — usage numbers appear here once agents start running it.

Anonymized aggregate across every org using this skill — proof from real production use, not a demo.

Does this skill help? · Benchmark: with vs. withoutsign in to run this on your agents

22 test cases from the publisher’s eval.yaml · each run twice on gemini-3.6-flash — with the skill injected, then without · last run 22d ago

No measurable change+15% tokens0% turns95% of whole cases pass with skill (21/22)

Test case	Without → With	Effect	Δ tokens	Δ turns
case-01	✓→✓	＝ Same ✓	-3%	0%
case-02	✓→✓	＝ Same ✓	3%	0%
case-03	✓→✓	＝ Same ✓	55%	0%
case-04	✓→✓	＝ Same ✓	65%	0%
case-05	✓→✓	＝ Same ✓	15%	0%

Showing 5 of 22 cases

SkillSafety

✓ 3 of 3 passed

Code scan15 of 15 checks clean

0 critical · 0 warning · 0 info — scanner v4 — 8/10/2026

live_secretremote_code_executionreverse_shelldata_exfiltrationssrf_metadataagent_snoopinganti_refusaldestructive_commandsobfuscated_unicodeunicode_homoglyphopaque_blobsuspicious_urltool_overreachtrigger_abuseprompt_injection_phrasing

IntentSafe

LLM judge · does the skill do what it claims

ContentClean

LLM judge · policy & harmful-content review

Source

Imported

dicklesworthstone / pi_agent_rust

tests/ext_conformance/artifacts/plugins-community/skills/06-backend-dev/kafka-producer-consumer/SKILL.md

View on GitHub ↗

License MITImported 8/10/2026Version v1

Skill contents

SKILL.md

Kafka Producer Consumer

Overview

This skill provides automated assistance for kafka producer consumer tasks within the Backend Development domain.

When to Use

This skill activates automatically when you:

Mention "kafka producer consumer" in your request
Ask about kafka producer consumer patterns or best practices
Need help with backend skills covering node.js, python, go, database design, caching, messaging, and microservices architecture.

Instructions

Provides step-by-step guidance for kafka producer consumer
Follows industry best practices and patterns
Generates production-ready code and configurations
Validates outputs against common standards

Examples

Example: Basic Usage Request: "Help me with kafka producer consumer" Result: Provides step-by-step guidance and generates appropriate configurations

Prerequisites

Relevant development environment configured
Access to necessary tools and services
Basic understanding of backend development concepts

Output

Generated configurations and code
Best practice recommendations
Validation results

Error Handling

| Error | Cause | Solution | |-------|-------|----------| | Configuration invalid | Missing required fields | Check documentation for required parameters | | Tool not found | Dependency not installed | Install required tools per prerequisites | | Permission denied | Insufficient access | Verify credentials and permissions |

Resources

Official documentation for related tools
Best practices guides
Community examples and tutorials

Related Skills

Part of the Backend Development skill category. Tags: nodejs, python, go, microservices, database

Illustrative Want to see what dicklesworthstone/kafka-producer-consumer would put in front of your model? Preview the rendered body and check its trigger phrases — no LLM call, no signup.

Latest benchmark · publisher runVerified

8/29/2026, 18:49 UTC · 22 cases

Lift

95% vs 95%

Agent turns

1.0 vs 1.0

Tokens

+15%

2,603.77 vs 2,261.5

pass → pass · 21fail → fail · 1

Per-case results (22)

Case	Status	Duration (ms)			Turns			Tokens			Tool calls
Case	Status	Without	With	Δ	Without	With	Δ	Without	With	Δ	Without	With	Δ
case-01 I am configuring a Python Kafka producer using confluent-kafka for a critical financial transaction stream where data loss cannot be tolerated. Should I set acks to 0, 1, or all (-1)?	pass→pass	15,109	20,078	+33%	1	1	0%	2,265	2,203	-3%	0	0	—
case-02 We are building a Node.js Kafka consumer using kafkajs to process order events and write them to PostgreSQL. To prevent processing data loss during unexpected service crashes, should enable.auto.commit be set to true or false?	pass→pass	16,835	13,328	-21%	1	1	0%	2,538	2,607	+3%	0	0	—
case-03 In a Go Kafka producer service built with sarama, we want to prevent message duplication caused by network retries without changing cluster partitioning. What specific producer property enables exact-once delivery semantics per partition on the producer side?	pass→pass	8,939	8,043	-10%	1	1	0%	1,223	1,900	+55%	0	0	—
case-04 We are deploying multiple replicas of a Go worker service that consumes from a shared Kafka topic. What consumer configuration setting ensures messages are distributed across instances rather than broadcast to every instance?	pass→pass	7,328	9,838	+34%	1	1	0%	1,249	2,062	+65%	0	0	—
case-05 When a Python Kafka consumer encounters a malformed JSON payload that repeatedly fails deserialization, what message pattern prevents the consumer from stalling partition consumption endlessly?	pass→pass	17,172	17,681	+3%	1	1	0%	2,630	3,028	+15%	0	0	—
case-06 We need to process user clickstream data in Node.js while guaranteeing that all events for a specific userId are processed strictly in chronological order. How should we partition the Kafka messages?	pass→pass	14,850	12,932	-13%	1	1	0%	2,371	2,656	+12%	0	0	—
case-07 Our Python Kafka consumer performs batch database updates before committing offsets. What handler mechanism should be implemented to commit pending offsets before partition ownership is reassigned to another consumer?	pass→pass	14,102	12,767	-9%	1	1	0%	2,521	2,793	+11%	0	0	—
case-08 A high-throughput telemetry service written in Go is saturating network bandwidth when producing logs to Kafka. How should we configure message batching and compression to optimize bandwidth usage?	pass→pass	16,759	16,992	+1%	1	1	0%	2,843	3,398	+20%	0	0	—
case-09 Our Node.js Kafka consumer processes heavy image processing tasks per record. It frequently gets dropped from the consumer group due to missed heartbeats. What consumer configuration should be increased to allow longer processing per batch?	pass→pass	11,651	14,686	+26%	1	1	0%	1,904	2,823	+48%	0	0	—
case-10 We are implementing a read-process-write pipeline across multiple Kafka topics using Python confluent-kafka. Which consumer isolation level prevents reading uncommitted messages from aborted transactions?	pass→pass	5,399	9,185	+70%	1	1	0%	1,061	1,994	+88%	0	0	—
case-11 To prevent breaking schema changes when microservices produce messages to shared Kafka topics, what architectural tool and serialization format standard should be integrated into the producer-consumer pipeline?	pass→pass	9,252	12,203	+32%	1	1	0%	1,604	2,724	+70%	0	0	—
case-12 A Node.js e-commerce microservice needs to update a MySQL database and publish an OrderCreated event to Kafka within a single atomic operation. How should this be designed to avoid dual-write inconsistencies?	pass→pass	18,774	17,918	-5%	1	1	0%	3,406	3,745	+10%	0	0	—
case-13 What primary metric should be monitored in Prometheus/Grafana to identify when a Go Kafka consumer service is falling behind the producer ingestion rate?	pass→pass	10,635	12,752	+20%	1	1	0%	1,733	2,124	+23%	0	0	—
case-14 When network glitches cause transient leader election errors during Kafka production, what configuration settings control retry behavior and delay intervals in Python kafka-python?	pass→pass	15,771	14,861	-6%	1	1	0%	2,984	3,133	+5%	0	0	—
case-15 When receiving a SIGTERM signal in a Node.js Kafka consumer application, what steps must be executed to shut down cleanly without losing progress?	pass→pass	16,565	18,407	+11%	1	1	0%	2,900	3,146	+8%	0	0	—
case-16 For a production Kafka topic requiring high availability across multi-broker failures, what minimum replication factor and min.insync.replicas settings are recommended?	pass→pass	14,845	11,388	-23%	1	1	0%	2,536	1,956	-23%	0	0	—
case-17 In Go sarama, how can we route high-priority customer events to dedicated partition index 0 while hashing all standard customer events across remaining partitions?	pass→pass	18,362	20,307	+11%	1	1	0%	3,466	3,829	+10%	0	0	—
case-18 A batch reconciliation worker in Python needs to re-process yesterday's data from a Kafka topic starting from a specific timestamp. How should the consumer adjust its position?	pass→pass	14,738	17,322	+18%	1	1	0%	2,834	2,963	+5%	0	0	—
case-19 If a Node.js Kafka producer sends messages faster than the broker can acknowledge, memory usage spikes and max block exceptions occur. What producer settings control memory allocation and blocking behavior?	fail→fail	17,817	17,307	-3%	1	1	0%	3,092	2,946	-5%	0	0	—
case-20 How do I center a div both vertically and horizontally using CSS Grid in a React frontend component?	pass→pass	10,941	8,559	-22%	1	1	0%	1,648	1,721	+4%	0	0	—
case-21 In Redis, what memory management policy should be configured to automatically remove the least recently used keys when memory limit is reached?	pass→pass	4,730	5,160	+9%	1	1	0%	951	1,359	+43%	0	0	—
case-22 We have a slow PostgreSQL query filtering by a JSONB column key in our backend service. What type of index should be created to optimize this query?	pass→pass	11,485	12,197	+6%	1	1	0%	1,994	2,173	+9%	0	0	—

These cases were also screened by the skill’s intent / safety pass.See the Trust review ↗Reproduce this benchmark in Colab ↗

How this skill was measured

DecimalAI ran this skill against gemini-3.6-flash twice over the same eval suite — once with the skill loaded and once without — and compared the two runs case by case. 22 cases were attempted. The headline lift of 0 percentage points is the difference between those two pass rates over the 22 comparable cases.

Model measured: gemini-3.6-flash
Graded by: gemini-3.6-flash
Grading method: judged
Verification: verified
Pass rate without the skill: 95.5%
Pass rate with the skill: 95.5%
Cases attempted: 22
Cases counted toward lift: 22
Cases that regressed: 0
Skill version measured: v1
Run completed: 8/29/2026, 18:49 UTC

SkillScore blends 4 signalsno signals yet

BenchmarkRun a verified benchmark with positive lift

Live evalNeeds ≥10 evaluated traces in 30 days

AI ratingNeeds ≥10 rated traces

AdoptionNeeds ≥10 serves across ≥2 orgs in 30 days

Efficiency · separate axis (at equal correctness)+0% turns+17% tokens

Shown for transparency; not credited unless a verified run shows no correctness regression.

No signals yet — run a benchmark or collect evaluated traces to earn a score.

Verified on gemini-3.6-flash · re-tested 22 days ago

Other measured skills in the registry, with their headline benchmark lift.