Можете ли вы указать вложенный ключ для таблицы в KSQL?

Question

Я пытаюсь создать таблицу из темы с ключом объекта, но KSQL не распознает переменную.

Есть ли какое-либо решение для этого?

create table csvexporttable (HEADER STRUCT<BusinessDate varchar>,
                             body STRUCT<ActiveStore_SalesTransaction_170 STRUCT<ThirdPartyLoyaltyData STRUCT<TotalAdvantage STRUCT<AdvantageAmount int>,CustomerNo varchar>,TransactionDetail ARRAY <STRUCT<TransactionDetailGroup STRUCT<item STRUCT<ManualPrice int,PriceOverride int>>,DetailFlagVoid int>>,SuspendFlag int,Total Array<STRUCT<TotalAmount DOUBLE>>>>) 
with (KAFKA_TOPIC='************',
      VALUE_FORMAT='JSON',
      KEY='HEADER->BusinessDate');

Answer 1

Структурированные ключи еще не поддерживаются KSQL. Вы можете подтвердить (+1) запрос функции на https://github.com/confluentinc/ksql/issues/824.