Skip to content

Releases

v0.2.0

v0.2.0 Latest
Latest

Choose a tag to compare

View all tags
@piscesff piscesff released this 08 Nov 17:39
v0.2.0
cdb6f4b
This commit was created on GitHub.com and signed with GitHub’s verified signature.
GPG key ID: B5690EEEBB952194
Verified
Learn about vigilant mode.

WolveKafka v0.2.0 adds distributed tracing across Kafka and lets handlers ask WKS to slow down. WKS is early-stage, so expect configuration and behavior to change between 0.x releases.

Highlights

  • Trace propagation: WKS reads W3C traceparent and baggage from Kafka record headers and passes the trace context to your handler. When a batch mixes traces, its span links to each of them. (#113)
  • OTLP span export: select an exporter with OTEL_TRACES_EXPORTER (otlp, console, or none) and the standard OTEL_EXPORTER_OTLP_* variables. (#113)
  • Throttling: a handler can return 429, or 503 with Retry-After, to pause delivery. Throttled attempts don't advance the backoff schedule or use up the retry budget, and the new wks.lambda.throttled metric counts them. Retry-After waits are capped at five minutes. (#114)
  • Quickstart: ./demo start now runs the released image by default. (#98)

Behavior changes

  • 429 responses, and 503 responses with Retry-After, no longer count toward retry exhaustion, so they no longer send records to the DLQ or drop action. A handler that throttles indefinitely holds its batch uncommitted, so watch wks.lambda.throttled.
  • An unrecognized OTEL_TRACES_EXPORTER value is now rejected at startup.
  • Spans still go to the console when no exporter or OTLP endpoint is configured. Set OTEL_TRACES_EXPORTER=none if you don't want them in your logs.

Artifacts

  • Linux amd64 / arm64 binaries, SHA256SUMS, and an SPDX source SBOM (attached below)
  • Container image: ghcr.io/wolveflake/wolvekafka:v0.2.0
  • Helm chart: oci://ghcr.io/wolveflake/charts/wks --version 0.2.0

See verifying a release.

Get started

git clone https://github.com/wolveflake/wolvekafka.git
cd wolvekafka
./demo start

Feedback is welcome in Issues and on Discord.

Assets 7
Loading

v0.1.0

v0.1.0

Choose a tag to compare

View all tags
@piscesff piscesff released this 04 Nov 18:09
v0.1.0
facddd2
This commit was created on GitHub.com and signed with GitHub’s verified signature.
GPG key ID: B5690EEEBB952194
Verified
Learn about vigilant mode.

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 / arm64 binaries, 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 start

Feedback, bug reports, and questions are welcome in Issues and Discussions.

Loading