Skip to content

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.