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.
Installs into .claude/skills of the current project.
Are you the author of Apache Kafka Stream Transformer 2?
Add the live security badge to your README. It updates with every re-scan.
[](https://www.skillsdirectory.com/skills/agentskillexchange-apache-kafka-stream-transformer-2)
---
name: "Apache Kafka Stream Transformer"
slug: "apache-kafka-stream-transformer-2"
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."
github_stars: 32377
verification: "security_reviewed"
source: "https://github.com/apache/kafka"
author: "apache"
category: "Data Extraction & Transformation"
framework: "Cursor"
tool_ecosystem:
github_repo: "apache/kafka"
github_stars: 32377
---
# Apache Kafka Stream Transformer
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.
## Installation
Use the upstream install or setup path that matches your environment:
- docker run -p 9092:9092 apache/kafka:latest
Requirements and caveats from upstream:
- Using docker image:
- See [docker/README.md](docker/README.md) for detailed information.
Basic usage or getting-started notes:
- ### Build a JAR and run it
- ### Run unit/integration tests
- ./gradlew test -Pkafka.test.run.flaky=true # runs tests that are marked as flaky
- Source: https://github.com/apache/kafka
- Extracted from upstream docs: https://raw.githubusercontent.com/apache/kafka/HEAD/README.md
## Documentation
- https://kafka.apache.org/documentation/
## Source
- [Agent Skill Exchange](https://agentskillexchange.com/skills/apache-kafka-stream-transformer-2/)
