如何在 Select 语句中选择记录的键

【问题标题】：How to select the Key of a Record in a Select statement如何在 Select 语句中选择记录的键
【发布时间】：2019-01-26 06:03:52
【问题描述】：

我创建了这条记录：

new ProducerRecord(topic = "petstore-msg-topic", key = msg.username, value = s"${msg.route},${msg.time}")

我现在想做这样的事情：

CREATE STREAM petstorePages (KEY, route VARCHAR, time VARCHAR) \
                  WITH (KAFKA_TOPIC='petstore-msg-topic', VALUE_FORMAT='DELIMITED');

是否有可能在 Stream 创建中访问密钥，还是我必须在值中也包含密钥？

【问题讨论】：

【解决方案1】：

它是自动添加的，叫做 ROWKEY

KSQL在每一个流和表中都添加了隐式列ROWTIME和ROWKEY，分别代表对应的Kafka消息时间戳和消息key

【讨论】：