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.
What it does
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
Capabilities
Install
Quality
deterministic score 0.45 from registry signals: · indexed on github topic:agent-skills · 8 github stars · SKILL.md body (1,013 chars)