Я создаю KTable из темы с форматом значений JSON, производители темы также включают ключ для каждого сообщения на уровне 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, чтобы мне не пришлось дублировать значение ключа на уровне темы?
