I am looking to incorporate the key value from a topic’s messages into a KSQLDB Stream to be a unique identifier. The keys are unique to what sensor the data is coming from. I am in a situation where the format of the messages coming from our topic cannot be changed and the three columns of data we are receiving do not have anything that would be able to identify what sensor that row came from. Is there a way to include the key from each topic message into the Stream?
I have seen some older posts online that refer to ROWKEY as something I can use in a select statement, but that cannot be resolved when I try it. I am only able to use ROWTIME.