apachekafka-Flink自定义分区器示例

自定义分区程序可能会有所帮助，但对于您的情况则不是必需的。

您只需从消息中提取分组值并将其用作分组 key。因此，在源读取数据之后，如果您想保留原始消息，您可以使用 map来提取数据类型为byte[]->Tuple2的值（如Record->（groupingValue，Record））。然后，可以使用.keyBy（0）并在其上应用任何运算符。keyBy确保Tuple2的第一个字段中具有相同值的所有记录都由同一个运算符处理。