// STRYKE-KAFKA — APACHE KAFKA CLIENT FOR STRYKE // PRODUCER + CONSUMER + ADMIN + CONSUMER-GROUP LAG

stryke package · CLI launcher kafka · Rust helper stryke-kafka-helper · opt-in (kept out of stryke core)

Report GitHub Issues
// Color scheme

>_STRYKE-KAFKA

Streams without the JVM. Apache Kafka client for stryke — producer, consumer, admin, and consumer-group lag. Opt-in package backed by rdkafka (librdkafka bindings).

Install

# build the helper binary, install as a stryke package
cd ~/projects/stryke-kafka
cargo build --release
s pkg install -g .

# one-liner
make install

# verify
kafka --help

After install, kafka --help works from anywhere on PATH (assuming ~/.stryke/bin/ is on PATH). The stryke library is auto-discoverable to any project that depends on the package via [deps] kafka = { path = "..." } or, when published, by name.

CLI: kafka

produce a messagekafka produce my-topic 'hello world'
consume from earliestkafka consume my-topic --from-beginning --json
list topicskafka topics list
create a topickafka topics create new-topic --partitions 12 --replication 3
consumer-group lagkafka lag my-group
describe brokerskafka brokers describe

The full flag matrix lives in the README "CLI" section.

Why a package, not a builtin

librdkafka is the canonical native Kafka client. Bundled here as an opt-in stryke package so workflows that need it don't bloat the core binary.

The stryke side is a thin NDJSON-pipe wrapper; the heavy code lives in the stryke-kafka-helper sidecar binary and is loaded on demand. Core stryke is never linked against this package's deps.

Helper protocol

The stryke-kafka-helper sidecar speaks newline-delimited JSON over stdin/stdout. The stryke library shells out per call and pipes structured data both ways. This keeps stryke startup small while making the package's surface area available on demand.

# manual invocation (debugging only)
echo '{"op":"version"}' | stryke-kafka-helper

Layout

stryke-kafka/
├── Cargo.toml             # bin = stryke-kafka-helper (publish = false)
├── src/
│   └── main.rs           # helper binary entry point
├── lib/                   # stryke .stk wrapper(s)
├── stryke.toml            # stryke package manifest
├── t/                     # zunit-style tests
├── examples/              # runnable .stk examples
├── Makefile               # `make install` builds + installs
└── docs/                  # this site (GitHub Pages)

Sibling packages

Part of the stryke connector family. Browse the others via the MenkeTechnologiesMeta umbrella repo (Tier 2):