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

Question

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

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

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

Answer 1

不，目前这在 KSQL 中是不可能的。 key 需要出现在消息值中以及 key 本身。

KSQL 5.2 的工作正在进行中，它将改进键的处理方式，敬请期待......