ksqldb - 您可以在 KSQL 中为表指定嵌套键吗?

标签 ksqldb

我正在尝试从具有对象键的主题创建表,但 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');

最佳答案

KSQL 尚不支持结构化键。您可以在 https://github.com/confluentinc/ksql/issues/824 上投票 (+1) 功能请求.

关于ksqldb - 您可以在 KSQL 中为表指定嵌套键吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56289365/

相关文章:

java - 编译 Confluence KsqlDB 时的类型转换问题

apache-kafka - Kafka KSQL Re分区和rekey问题

apache-kafka - 用KSQL计算所有条目

apache-kafka - KSQL 流 - 从结构数组中获取数据

apache-kafka - 如何在通过指定主题名称创建流形式模式注册表时在 ksql 中保留字段区分大小写

rest - Kafka Rest API KSQL 查询永远等待并挂起

docker - 在docker中将ksql与融合版本3.3.0的kafka连接的问题

apache-kafka - 为什么 KSQL 查询从流-流连接创建的流中返回空值?

confluent-platform - 使用 KSQL,为什么我的表保留较旧 ROWTIME 的数据并丢弃较新 ROWTIME 的更新?