apache-kafka - 使用与 Kafka 主题消息键相同的 ROWKEY 创建 KSQL 表

Question

我正在从具有 JSON 值格式的主题创建 KTable，该主题的生产者还包括 Kafka 级别的每条消息的键，并且 JSON 消息本身包含一个名为 JSON 的属性key，我ROWKEY在以下语句中使用该属性：

create table SUBSCRIPTIONS(key varchar, application_id varchar, subscription_id varchar) with (KAFKA_TOPIC='INCOMING_SUBSCRIPTIONS', VALUE_FORMAT='JSON', KEY='key');

有没有办法使用主题中消息中的键创建 KSQL 表，ROWKEY这样我就不必在主题级别复制键值？

标签： apache-kafkaksqldb

Answer 1

不，这在 KSQL 中目前是不可能的。密钥需要存在于消息值以及密钥本身中。

KSQL 5.2 正在改进密钥的处理方式，敬请期待……</p>