All Packages

Package Summary

Package	Description
io.krabka.streams	Defaults and entry points for Apache Kafka Streams applications.
io.krabka.streams.columnar	Apache Arrow batch codecs, topology operators, runners, and state handling.
io.krabka.streams.columnar.barrier	Barrier-aligned, epoch-keyed state snapshots for columnar runners.
io.krabka.streams.columnar.schema	Avro and Protobuf bridges into the Arrow columnar runtime.
io.krabka.streams.coordination	Leader election, leases, and fencing tokens for one role.
io.krabka.streams.schema	Confluent-wire-compatible Avro, Protobuf, and JSON Schema serdes.
io.krabka.streams.test	In-memory columnar and schema-registry test helpers.