0

我需要按 kSQLDB 表中的多个列进行分组,并且我知道 KSQLDB 将自动使用这些列作为 kafka 主题的分区键。但是,我不希望通过这些键对基础主题进行分区

Example:
Customer | Phone | Type   | Year
ABC      | 123   | home.  | 1999
ABC      | 345   | office | 1999
ABC      | 768.  | home.  | 1999
ABC      | 567.  | home.  | 2000

我想创建一个 KSQLDB 表来按客户、类型和年份分组,以消除第一条或第三条记录。但是,一旦我这样做,该主题将被所有 3 个字段划分,并且我失去了对消息排序的控制。我希望分区只对客户起作用,并为每个客户保留消息的顺序。

Failed to prepare statement: Queries only support one of PARTITION BY and GROUP BY

有没有办法将 group by 与分区键分开?

4

0 回答 0