github.com/krabka-io/krabka-streams-go
API reference, generated from the package documentation. See the repository for guides and examples.
| Package | Synopsis |
|---|---|
| github.com/ | Package krabkastreams applies the client settings that a krabka streams group needs. |
| github.com/ | Package columnar processes Kafka records as Apache Arrow batches instead of one record at a time. |
| github.com/ | Package columnarschema connects the schema registry serdes to columnar topologies. |
| github.com/ | Package coordination elects one leader per role, and it proves that leadership on every guarded write. |
| github.com/ | Package krabkatest bundles test helpers for the schema and columnar packages: an in-memory schema registry server and an in-process driver for columnar topologies. |
| github.com/ | Package schema talks to a Confluent-compatible schema registry and provides Avro, Protobuf, and JSON Schema serdes over the Confluent wire format. |