kafka-streams-internals-ConsumedInternal.adoc

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:

• Deserializer of keys (only when Serde for keys is defined)

• Deserializer of values (only when Serde for values is defined)

• Offset reset policy (Topology.AutoOffsetReset)

• TimestampExtractor

ConsumedInternal takes a single Consumed, its parts or none at all (that are used to create a Consumed) when created:

• Key Serde

• Value Serde

• TimestampExtractor

• Offset reset policy (Topology.AutoOffsetReset)

ConsumedInternal is created when:

• StreamsBuilder is requested to stream, table, globalTable, and addGlobalStore

• KStreamImpl is requested to through