Создайте таблицу KSQL с ROWKEY так же, как ключ сообщения темы Kafka

Question

Я создаю KTable из темы в формате значения JSON, производители темы также включают ключ для каждого сообщения на уровне Kafka, а само сообщение JSON содержит свойство JSON с именем key, которое я использую как * 1002.* в следующем утверждении:

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

Есть ли способ создать таблицу KSQL, используя ключ из сообщений в теме как ROWKEY, поэтому мне не нужно дублировать значение ключа приуровень темы?

Answer 1

Нет, в настоящее время это невозможно в KSQL.Ключ должен присутствовать в значении сообщения, а также в самом ключе.

В KSQL 5.2 ведется работа над улучшением работы с ключами, так что следите за обновлениями ...