flink sql 分区写入 kafka 阳历

Flink SQL 分区写入 Kafka 的流程大概如下：

1. 使用 Flink SQL 定义数据源，可以是文件、Kafka 等，这里假设数据源是文件。

2. 使用 Flink SQL 进行数据转换和处理，例如过滤、聚合、排序等。

3. 使用 Flink SQL 定义要写入 Kafka 的目标表，包括表结构和分区键等。例如：

   CREATE TABLE kafka_sink (
     id INT,
     name STRING,
     event_time TIMESTAMP(3),
     WATERMARK FOR event_time AS event_time - INTERVAL '5' SECOND
   ) WITH (
     'connector' = 'kafka',
     'topic' = 'mytopic',
     'properties.bootstrap.servers' = 'localhost:9092',
     'format' = 'json',
     'partitioner' = 'round-robin',
     'sink.partition-key' = 'event_time'
   )

这里使用 Kafka 作为 Sink，将数据写入到名为 `mytopic` 的 Kafka Topic 中，并使用 `event_time` 字段作为分区键，使用 Round-Robin 分区器将数据均匀地写入 Kafka 的不同分区中。

4. 在 Flink SQL 中将数据写入目标表，例如：

   INSERT INTO kafka_sink
   SELECT id, name, event_time
   FROM file_source

这里假设数据源是一个名为 `file_source` 的 Flink SQL 表，将其中的数据写入 `kafka_sink` 表中。

需要注意的是，Flink SQL 会根据定义的分区键将数据均匀地分配到不同的 Kafka 分区中，从而实现分区写入。