使用与 Kafka 主题消息键相同的 ROWKEY 创建 KSQL 表答案

【问题标题】：Create KSQL table with ROWKEY same as Kafka topic message key使用与 Kafka 主题消息键相同的 ROWKEY 创建 KSQL 表
【发布时间】：2019-06-22 14:39:39
【问题描述】：

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

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

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

【问题讨论】：

标签： apache-kafka ksqldb

【解决方案1】：

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

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

【讨论】：

你好，今天这个是什么状态？
从 5.3 开始，情况没有改变。