krabka streams for Java 1.4.2
krabka streams for Java is the Java client library for stream processing with krabka. It exports the Apache Kafka Streams API unchanged and adds krabka schema registry serdes and Apache Arrow columnar batch processing.
The API is split across four artifacts, one per package group below. Each artifact
depends on io.krabka:krabka-streams, so any one of them pins the Kafka
Streams API version. See the
guides
for configuration, broker requirements, and worked examples.
Package
Description
Defaults and entry points for Apache Kafka Streams applications.
Apache Arrow batch codecs, topology operators, runners, and state handling.
Barrier-aligned, epoch-keyed state snapshots for columnar runners.
Avro and Protobuf bridges into the Arrow columnar runtime.
Leader election, leases, and fencing tokens for one role.
Confluent-wire-compatible Avro, Protobuf, and JSON Schema serdes.
In-memory columnar and schema-registry test helpers.