Hello all,

I was wondering if it is possible to add the message key value to a structure 
in KSQL. My coworker has a specific need where the key values of the messages 
should be in the same structure as the other values he is collecting.


We were hoping something like this would work, but it will not accept that as a 
value:
CREATE STREAM PI_STREAM_01 ("Structure" STRUCT<"keyValue" VARCHAR KEY, "Value" 
VARCHAR>) WITH (KAFKA_TOPIC='lift_twelve', VALUE_FORMAT='KAFKA');


Thank you,

Andrew Greer

Reply via email to