Package io.krabka.streams.test

package io.krabka.streams.test

In-memory columnar and schema-registry test helpers.

Example

var driver = new ColumnarTestDriver(topology.build());
driver.pipeInput("input", 0, key, value, 0L);
assertThat(driver.readOutput("output"))
    .usingRecursiveComparison()
    .isEqualTo(expected);

Related Packages

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.coordination	Leader election, leases, and fencing tokens for one role.
io.krabka.streams.schema	Confluent-wire-compatible Avro, Protobuf, and JSON Schema serdes.

Classes

Class	Description
ColumnarTestDriver	Runs a columnar topology without a broker.
SchemaRegistryStub	A small, stateful Confluent Schema Registry test server.