{"id":"a826f371-976a-4b2d-82d1-f4f7602c2463","shortId":"HB2yXy","kind":"skill","title":"Apache Kafka Stream Transformer","tagline":"Processes real-time event streams using KafkaJS consumer groups and transforms messages with configurable schemas. Handles partition rebalancing, offset commits, and dead-letter queue routing for failed transformations.","description":"# Apache Kafka Stream Transformer\n\nProcesses real-time event streams using KafkaJS consumer groups and transforms messages with configurable schemas. Handles partition rebalancing, offset commits, and dead-letter queue routing for failed transformations.\n\n## Installation\n\nUse the upstream install or setup path that matches your environment:\n- docker run -p 9092:9092 apache/kafka:latest\n\nRequirements and caveats from upstream:\n- Using docker image:\n- See [docker/README.md](docker/README.md) for detailed information.\n\nBasic usage or getting-started notes:\n- ### Build a JAR and run it\n- ### Run unit/integration tests\n- ./gradlew test -Pkafka.test.run.flaky=true # runs tests that are marked as flaky\n\n- Source: https://github.com/apache/kafka\n- Extracted from upstream docs: https://raw.githubusercontent.com/apache/kafka/HEAD/README.md\n\n## Documentation\n\n- https://kafka.apache.org/documentation/\n\n## Source\n\n- [Agent Skill Exchange](https://agentskillexchange.com/skills/apache-kafka-stream-transformer-2/)","tags":["apache","kafka","stream","transformer","skills","agentskillexchange","agent-skills","ai-agents","ai-tools","awesome-list","claude-code","codex"],"capabilities":["skill","source-agentskillexchange","skill-apache-kafka-stream-transformer-2","topic-agent-skills","topic-ai-agents","topic-ai-tools","topic-awesome-list","topic-claude-code","topic-codex","topic-cursor","topic-llm","topic-mcp","topic-npx-skills","topic-openclaw","topic-skills-catalog"],"categories":["skills"],"synonyms":[],"warnings":[],"endpointUrl":"https://skills.sh/agentskillexchange/skills/apache-kafka-stream-transformer-2","protocol":"skill","transport":"skills-sh","auth":{"type":"none","details":{"cli":"npx skills add agentskillexchange/skills","source_repo":"https://github.com/agentskillexchange/skills","install_from":"skills.sh"}},"qualityScore":"0.454","qualityRationale":"deterministic score 0.45 from registry signals: · indexed on github topic:agent-skills · 8 github stars · SKILL.md body (1,013 chars)","verified":false,"liveness":"unknown","lastLivenessCheck":null,"agentReviews":{"count":0,"score_avg":null,"cost_usd_avg":null,"success_rate":null,"latency_p50_ms":null,"narrative_summary":null,"summary_updated_at":null},"enrichmentModel":"deterministic:skill-github:v1","enrichmentVersion":1,"enrichedAt":"2026-05-18T19:09:22.778Z","embedding":null,"createdAt":"2026-05-18T13:15:05.390Z","updatedAt":"2026-05-18T19:09:22.778Z","lastSeenAt":"2026-05-18T19:09:22.778Z","tsv":"'/apache/kafka':132 '/apache/kafka/head/readme.md':139 '/documentation/':143 '/gradlew':118 '/skills/apache-kafka-stream-transformer-2/)':150 '9092':84,85 'agent':145 'agentskillexchange.com':149 'agentskillexchange.com/skills/apache-kafka-stream-transformer-2/)':148 'apach':1,35 'apache/kafka':86 'basic':102 'build':109 'caveat':90 'commit':25,59 'configur':19,53 'consum':13,47 'dead':28,62 'dead-lett':27,61 'detail':100 'doc':136 'docker':81,94 'docker/readme.md':97,98 'document':140 'environ':80 'event':9,43 'exchang':147 'extract':133 'fail':33,67 'flaki':128 'get':106 'getting-start':105 'github.com':131 'github.com/apache/kafka':130 'group':14,48 'handl':21,55 'imag':95 'inform':101 'instal':69,73 'jar':111 'kafka':2,36 'kafka.apache.org':142 'kafka.apache.org/documentation/':141 'kafkaj':12,46 'latest':87 'letter':29,63 'mark':126 'match':78 'messag':17,51 'note':108 'offset':24,58 'p':83 'partit':22,56 'path':76 'pkafka.test.run.flaky':120 'process':5,39 'queue':30,64 'raw.githubusercontent.com':138 'raw.githubusercontent.com/apache/kafka/head/readme.md':137 'real':7,41 'real-tim':6,40 'rebalanc':23,57 'requir':88 'rout':31,65 'run':82,113,115,122 'schema':20,54 'see':96 'setup':75 'skill':146 'skill-apache-kafka-stream-transformer-2' 'sourc':129,144 'source-agentskillexchange' 'start':107 'stream':3,10,37,44 'test':117,119,123 'time':8,42 'topic-agent-skills' 'topic-ai-agents' 'topic-ai-tools' 'topic-awesome-list' 'topic-claude-code' 'topic-codex' 'topic-cursor' 'topic-llm' 'topic-mcp' 'topic-npx-skills' 'topic-openclaw' 'topic-skills-catalog' 'transform':4,16,34,38,50,68 'true':121 'unit/integration':116 'upstream':72,92,135 'usag':103 'use':11,45,70,93","prices":[{"id":"818ec047-3c88-4d34-8213-dd6275abad28","listingId":"a826f371-976a-4b2d-82d1-f4f7602c2463","amountUsd":"0","unit":"free","nativeCurrency":null,"nativeAmount":null,"chain":null,"payTo":null,"paymentMethod":"skill-free","isPrimary":true,"details":{"org":"agentskillexchange","category":"skills","install_from":"skills.sh"},"createdAt":"2026-05-18T13:15:05.390Z"}],"sources":[{"listingId":"a826f371-976a-4b2d-82d1-f4f7602c2463","source":"github","sourceId":"agentskillexchange/skills/apache-kafka-stream-transformer-2","sourceUrl":"https://github.com/agentskillexchange/skills/tree/main/skills/apache-kafka-stream-transformer-2","isPrimary":false,"firstSeenAt":"2026-05-18T13:15:05.390Z","lastSeenAt":"2026-05-18T19:09:22.778Z"}],"details":{"listingId":"a826f371-976a-4b2d-82d1-f4f7602c2463","quickStartSnippet":null,"exampleRequest":null,"exampleResponse":null,"schema":null,"openapiUrl":null,"agentsTxtUrl":null,"citations":[],"useCases":[],"bestFor":[],"notFor":[],"kindDetails":{"org":"agentskillexchange","slug":"apache-kafka-stream-transformer-2","github":{"repo":"agentskillexchange/skills","stars":8,"topics":["agent-skills","ai-agents","ai-tools","awesome-list","claude-code","codex","cursor","llm","mcp","npx-skills","openclaw","skills-catalog"],"license":"mit","html_url":"https://github.com/agentskillexchange/skills","pushed_at":"2026-05-18T19:02:17Z","description":"The open catalog of AI agent skills — 2,000+ security-scanned skills for Claude Code, Cursor, Codex, and more.","skill_md_sha":"40dbc0f2fe14765d936c7a9f63be92ec613ab3b0","skill_md_path":"skills/apache-kafka-stream-transformer-2/SKILL.md","default_branch":"main","skill_tree_url":"https://github.com/agentskillexchange/skills/tree/main/skills/apache-kafka-stream-transformer-2"},"layout":"multi","source":"github","category":"skills","frontmatter":{"name":"Apache Kafka Stream Transformer","description":"Processes real-time event streams using KafkaJS consumer groups and transforms messages with configurable schemas. Handles partition rebalancing, offset commits, and dead-letter queue routing for failed transformations."},"skills_sh_url":"https://skills.sh/agentskillexchange/skills/apache-kafka-stream-transformer-2"},"updatedAt":"2026-05-18T19:09:22.778Z"}}