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.

agentskillexchange Updated 28 repo stars

File contents

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:

Documentation

Source

agentskillexchange/skills/tree/main/skills/apache-kafka-stream-transformer-2 commit 3475137e21

Frequently asked questions

npx skillmds@latest add agentskillexchange/apache-kafka-stream-transformer