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.
Install
npx skills add https://github.com/agentskillexchange/skills/tree/main/skills/apache-kafka-stream-transformer-2
claude plugin marketplace add https://llmmart.ai/marketplace.json && claude plugin install agentskillexchange-skills@llmmart
git clone https://github.com/agentskillexchange/skills.git
The skills CLI installs just this skill, for any of its supported agents. Claude Code installs the whole agentskillexchange/skills collection as a plugin from our marketplace. Git is the plain clone.
Skill manifest
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 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
Source
Files (skills)
-
SKILL.md 1.5 KB
--- 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/)
Comments (0)
Sign in to join the conversation.
Reviews (0)
No reviews yet.
No comments yet.