如何从具有复合键的主题创建 KSQL 表? [英] How to create KSQL table from a topic with composite key?

问题描述

我有一些带有 stringA stringB 字段的主题数据，我只是想在从主题创建 KSQL 表时将其用作键.

I have some topic data with the fields stringA stringB and I am just trying to use that as the key when creating a KSQL table from a topic.

推荐答案

只是对@Robin Moffat 的更新..使用下面的

Just an update to @Robin Moffat.. Use the below

CREATE STREAM TEST_REKEY AS 
        SELECT STRINGA + STRINGB AS MY_COMPOSITE_KEY, 
               STRINGA, 
               STRINGB, 
               COL3 
          FROM TEST 
          PARTITION BY STRINGA + STRINGB ;

代替

CREATE STREAM TEST_REKEY AS 
        SELECT STRINGA + STRINGB AS MY_COMPOSITE_KEY, 
               STRINGA, 
               STRINGB, 
               COL3 
          FROM TEST 
          PARTITION BY MY_COMPOSITE_KEY ;

注意:列顺序很重要为我工作！(CLI v0.10.1，服务器 v0.10.1)

NOTE: column ordering matters Worked for me! (CLI v0.10.1, Server v0.10.1)

这篇关于如何从具有复合键的主题创建 KSQL 表?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！