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

Question

我创建了这条记录:

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 创建中访问 key ，或者我是否必须在值中也包含 key ？

Answer 1

它是自动添加的，叫做ROWKEY

KSQL adds the implicit columns ROWTIME and ROWKEY to every stream and table, which represent the corresponding Kafka message timestamp and message key

https://docs.confluent.io/current/ksql/docs/syntax-reference.html#id16