git:20260710.2925510 to git:20260710.62afd0f
20 added, 13 removed. Audit B to B.
---
- title: "Apache Kafka Stream Processor"
- description: "Apache Kafka Stream Processor is built around Apache Kafka event streaming platform. The underlying ecosystem is represented by tulios/kafkajs (active GitHub adoption). It gives an agent a more technical and reliable way to work with the tool than a thin one-line wrapper, using stable interfaces like topics, partitions, consumer groups, offsets, producers, admin APIs and […]"
+ name: "Apache Kafka Stream Processor"
+ slug: "apache-kafka-stream-processor"
+ description: ""
+ github_stars: 32373
verification: "security_reviewed"
source: "https://github.com/apache/kafka"
author: "apache"
- category:
- - "Data Extraction & Transformation"
- framework:
- - "Custom Agents"
+ category: "Data Extraction & Transformation"
+ framework: "Custom Agents"
tool_ecosystem:
github_repo: "apache/kafka"
github_stars: 32373
---
# Apache Kafka Stream Processor
- Apache Kafka Stream Processor is built around Apache Kafka event streaming platform. The underlying ecosystem is represented by tulios/kafkajs (active GitHub adoption). It gives an agent a more technical and reliable way to work with the tool than a thin one-line wrapper, using stable interfaces like topics, partitions, consumer groups, offsets, producers, admin APIs and […]
+
## Prerequisites
Java
## Installation
- Choose whichever fits your setup:
+ Use the upstream install or setup path that matches your environment:
+ - docker run -p 9092:9092 apache/kafka:latest
- 1. Copy this skill folder into your local skills directory.
- 2. Clone the repo and symlink or copy the skill into your agent workspace.
- 3. Add the repo as a git submodule if you manage shared skills centrally.
- 4. Install it through your internal provisioning or packaging workflow.
- 5. Download the folder directly from GitHub and place it in your skills collection.
+ 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-processor/)