ConsumedInternal — Internal Accessors to Consumed Metadata
ConsumedInternal is a Consumed that is used internally as an accessor object to the following properties of the managed Consumed instance:
-
Deserializerof keys (only when Serde for keys is defined) -
Deserializerof values (only when Serde for values is defined) -
Offset reset policy (Topology.AutoOffsetReset)
ConsumedInternal takes a single Consumed, its parts or none at all (that are used to create a Consumed) when created:
-
Offset reset policy (Topology.AutoOffsetReset)
ConsumedInternal is created when:
-
StreamsBuilderis requested to stream, table, globalTable, and addGlobalStore -
KStreamImplis requested to through