Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

Can you specify a nested key for a table in KSQL?

Tags:

ksqldb

I'm trying to create a table from a topic with an object key, but KSQL didn't recognize the variable.

Any solution for this?

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');
like image 869
wahib Avatar asked Dec 04 '25 16:12

wahib


1 Answers

Structured keys are not yet supported by KSQL. You can upvote (+1) the feature request at https://github.com/confluentinc/ksql/issues/824.

like image 150
Michael G. Noll Avatar answered Dec 08 '25 06:12

Michael G. Noll



Donate For Us

If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!