kafka-stream-processor

Kafka Stream Processor - Auto-activating skill for Data Pipelines. Triggers on: kafka stream processor, kafka stream processor Part of the Data Pipelines skill category.

1.00x

Quality

Does it follow best practices?

Impact

96%

1.00x

Average score across 3 eval scenarios

Securityby

Passed

No known issues

Optimize this skill with Tessl

npx tessl skill review --optimize ./planned-skills/generated/11-data-pipelines/kafka-stream-processor/SKILL.md

Evaluation results

100%

Payment Transaction Kafka Consumer

Production-ready Kafka consumer

Criteria

Without context

With context

Error handling present

100%

Dead-letter or error routing

100%

Consumer group configured

100%

Offset management

100%

External configuration

100%

Documented config defaults

100%

Structured logging

100%

Graceful shutdown

100%

Deserialization handling

100%

README covers config options

100%

No hardcoded broker address

100%

Without context: $0.4505 · 1m 54s · 22 turns · 23 in / 7,143 out tokens

With context: $0.6035 · 2m 11s · 32 turns · 113 in / 8,339 out tokens

100%

Clickstream ETL: Raw Events to Warehouse-Ready Records

ETL data transformation pipeline

Criteria

Without context

With context

Schema defined

100%

Timestamp normalization

100%

Invalid records separated

100%

Rejection reason recorded

100%

Malformed JSON handled

100%

Valid output file produced

100%

Output schema consistent

100%

Summary report produced

100%

Counts add up

100%

Validation against schema

100%

No silent data loss

100%

Without context: $0.4936 · 1m 48s · 23 turns · 24 in / 7,194 out tokens

With context: $0.5723 · 2m 3s · 29 turns · 28 in / 7,931 out tokens

90%

Real-Time IoT Sensor Aggregation Pipeline

Streaming stateful aggregation

Criteria

Without context

With context

Tumbling window logic

100%

Configurable window size

100%

Per-sensor grouping

100%

Min/max/avg computed

100%

Count included

100%

Window boundaries in output

100%

Multiple windows produced

100%

Topology documented

100%

Correct average calculation

Multiple sensors handled

100%

No crashes on valid input

100%

Without context: $0.4877 · 1m 50s · 23 turns · 24 in / 7,328 out tokens

With context: $0.5396 · 2m 10s · 26 turns · 318 in / 7,962 out tokens

Repository: jeremylongshore/claude-code-plugins-plus-skills
Commit: 0c08951

Evaluated: 18 days ago
Agent: Claude Code
Model: Claude Sonnet 4.6

Table of Contents

Payment Transaction Kafka Consumer Clickstream ETL: Raw Events to Warehouse-Ready Records Real-Time IoT Sensor Aggregation Pipeline

Is this your skill?

If you maintain this skill, you can claim it as your own. Once claimed, you can manage eval scenarios, bundle related skills, attach documentation or rules, and ensure cross-agent compatibility.