Timo Walther created FLINK-33497: ------------------------------------ Summary: Update the Kafka connector to support DISTRIBUTED BY clause Key: FLINK-33497 URL: https://issues.apache.org/jira/browse/FLINK-33497 Project: Flink Issue Type: Sub-task Components: Connectors / Kafka Reporter: Timo Walther
The Kafka connector can be one of the first connectors supporting the DISTRIBUTED BY clause. The clause can be translated into 'key.fields' and 'properties.num.partitons' in the WITH clause. -- This message was sent by Atlassian Jira (v8.20.10#820010)