Skip to main content

Module config

Module config 

Source
Expand description

DSL config objects that mirror the JVM Grouped, Materialized, and Repartitioned.

Consumed and Produced come from crate::processor::serde.

Structsยง

Grouped
The serdes, and an optional repartition name, for groupBy and groupByKey.
Joined
Stream-table join config (KIP-923).
Materialized
The store name, the serdes, and the logging flag for a materialized KTable.
Repartitioned
The serdes, and an optional name and partition count, for an explicit repartition().
StreamJoined
The serdes for a windowed KStream-KStream join, the StreamJoined.
VersionedConfig
Versioned-store settings for a Materialized (KIP-889).