Ksql table column from message key

ksqlDB
1

When creating a stream or a table using an existing topic, how do I tell ksql to create key column using Kafka message key?

2

Hey there! The ksqlDB reference docs are pretty good, but just to summarize:

  • When creating a stream from an existing topic, any column marked KEY will be pulled from the key of the incoming message.
  • When creating a table from an existing topic, any columns marked PRIMARY KEY will be pulled from the key of the incoming message.

Hope that helps!

3

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