Pseudocolumns¶
ksqlDB exposes the timestamp, partition and offset of Kafka records as pseudocolumns.
Pseudocolumns are SystemColumns to access record metadata in KSQL statements:
ROWTIME
ROWPARTITION
ROWOFFSET
Pseudocolumns are enabled using ksql.rowpartition.rowoffset.enabled
ksqlDB 0.23.1
ROWPARTITION
and ROWOFFSET
were added in ksqlDB 0.23.1.