All Classes and Interfaces
Class
Description
Built-in within-batch aggregate functions.
Defines one aggregation, with an optional explicit output type.
A Kafka serde for Arrow IPC stream batches.
Type-coercing Arrow batch helpers for
RowBridge and
ColumnarProcessor implementations.Translates Avro schemas into Arrow schemas.
Decodes registry-framed Avro topics into Arrow batches and encodes them back.
Converts Avro records to and from Arrow batches with schema-derived columns.
A Kafka serde for Confluent-framed Avro values.
Tells a group runner which barrier group to align on.
One epoch's cut across every partition of a barrier group.
Decodes the cut records of the internal
__barrier_state topic.Reads published cuts from the internal
__barrier_state topic.Whether a barrier coordinator reached every partition of a cut.
Receives a cut when a runner reaches the barrier.
Converts one partition batch between Kafka records and Arrow vectors.
Converts records whose values are Arrow IPC batches.
A validated and reusable columnar topology.
Creates the built-in Arrow batch operators.
A source of the current time.
Collects batches that a columnar processor forwards.
Selects how a group runner handles a failed logical partition batch.
The reaction to a failed partition batch.
Reports an Arrow codec, topology, or operator failure.
Configuration for an inner, event-time, equi-join.
Lock-free counters for a columnar runner.
One point-in-time view of the counters.
An opaque handle to a columnar topology node.
Processes one Arrow batch and forwards zero or more output batches.
Runs fetch, process, asynchronously produce, and commit cycles.
A consumer-group runner that manages rebalances and persistent operator state.
Persists operator snapshots for one logical Kafka partition and one epoch.
A closeable snapshot-retention lease without checked exceptions.
Runs a columnar topology without a broker.
A linear or branching graph whose edges carry Arrow batches.
Encodes and decodes Confluent schema registry frames.
A decoded frame.
A decoded Protobuf frame.
One input record in a partition batch.
Elects one leader per role over a
CoordinationTransport.Encodes and decodes the frozen records of the internal
__coordination_state
topic.One decoded record of
CoordinationCodec.TOPIC, with the offset it sits at.Reports a coordination failure.
The decoded key of one record of
CoordinationCodec.TOPIC.The seam between the succession rules and the cluster.
One decoded value of
CoordinationCodec.TOPIC.What one member does about a role right now.
The step that one member takes about a role.
Defines a column that a with-columns operator adds or replaces.
Reports that the broker refused a write, because another member holds the role now.
The quorum-minted proof that one member holds a role.
Stores each partition snapshot in one atomically replaced local file.
Adds per-record GZIP compression to any batch codec.
Converts JSON-compatible Java records to flat Arrow columns.
A Kafka serde for Confluent-framed JSON Schema values.
The
CoordinationTransport that talks to a Kafka cluster.A nonblocking client for the Confluent Schema Registry REST API.
A schema fetched by ID, with unresolved references.
One registered version of a subject.
A schema fetched by ID with every transitive reference resolved to its text.
A reference from one schema to a version of another subject.
Applies the client settings that a krabka streams group needs.
The live leadership of one role by one member.
What one role looks like to a third party right now.
The member that holds a role now, and the time its claim ends.
The lease timings of one role.
The lease clock of one lease record under one policy.
Pairwise, network-free schema compatibility checks.
The direction of a compatibility check, mirroring registry compatibility levels.
The outcome of one compatibility check.
A clock that a caller moves by hand.
The validated identity of one member that competes for a role.
Binds one produced record to its sink topic.
One output record from a columnar sink.
Translates Protobuf message descriptors into Arrow schemas.
Decodes registry-framed Protobuf topics into Arrow batches and encodes them back.
Converts Protobuf messages to and from Arrow batches with descriptor-derived
columns.
A Kafka serde for Confluent-framed Protobuf messages.
One immutable Kafka record header.
Which record of
CoordinationCodec.TOPIC a key names.Defines how prewarming resolves a schema ID.
One member of a role announces that it is available.
The validated name of one coordination role, such as the name of an active
controller.
Identifies whether a schema belongs to a record key or value.
Computes the partition of
CoordinationCodec.TOPIC that holds every record of
one role.The state that a reader folds out of the records of one role.
Folds the records of one role into a
RoleState.One member of the roster of a role.
Converts typed rows to and from an Arrow payload batch.
Converts ordinary Kafka value records through a typed row bridge.
Tests one row in an Arrow batch.
Computes one derived Arrow column value.
Stores schema IDs and writer schemas for synchronous serde operations.
The per-subject outcome of
SchemaCache.prewarmReport().Signals that a background writer-schema fetch has not completed.
Schema formats supported by the registry client.
Reports a schema registry transport, status, or response error.
A small, stateful Confluent Schema Registry test server.
A processor whose partition-local state can be snapshotted and restored.
Maps a topic and record role to a schema registry subject.
The succession rules of one role: ordered candidates, and no failback.
Uses the Confluent topic naming rule.