Metadata columns from a topic in ksqldb stream/table

Hi All,

Is it possible to get the metadata values of topic name, partition, offset and timestamp from an underlying topic of a ksql stream?

Thank you!

You can access the timestamp via the ROWTIME (pseudo/system) column, that is present for every STREAM or TABLE.

Topic name, partition, and offset are not exposed atm, but it’s already WIP. The goal is to release this new feature with ksqlDB 0.23 or 0.24: ksql/ at c09c362294c8a51c6484e4a3ee995d25bbf487d1 · confluentinc/ksql · GitHub

Thanks for the information!

This topic was automatically closed 7 days after the last reply. New replies are no longer allowed.