Repository navigation
v0.1.0
First public release of WolveKafka (WKS): consume Kafka with an HTTP handler, in any language.
WKS runs the consumer groups and POSTs record batches to your HTTP endpoint. Your handler returns SUCCESS, RETRY, or FAILED per record; WKS commits, retries with backoff, or writes to a dead-letter topic. WKS is early-stage, so expect configuration and behavior to change between 0.x releases.
Highlights
- At-least-once delivery: offsets are committed only after the handler succeeds
- Per-record results with exponential-backoff retry and DLQ or drop on failure
- Batch mode (size/bytes/wait) or parallel mode (N workers)
- Weighted routing across multiple handler targets
- Optional output: produce handler responses back to Kafka
- Hot-reload of consumer configuration without a redeploy
- OpenTelemetry metrics and a ready-made Grafana dashboard
Artifacts
- Linux
amd64/arm64binaries,SHA256SUMS, and an SPDX source SBOM (attached below) - Container image:
ghcr.io/wolveflake/wolvekafka:v0.1.0 - Helm chart:
oci://ghcr.io/wolveflake/charts/wks --version 0.1.0
See verifying a release.
Get started
git clone https://github.com/wolveflake/wolvekafka.git
cd wolvekafka
./demo startFeedback, bug reports, and questions are welcome in Issues and Discussions.