Hi, watermark 可以在 keyBy 后分配，但是最好紧跟 SourceFunction。经过 KeyBy 或其他分配策略，可能导致数据更大的延迟（EventTime）。
“想做key化的乱序处理” 这句没太理解，麻烦解释下。 | | Jimmy Wong | | [email protected] | 签名由网易邮箱大师定制 在2020年03月30日 20:58，tingli ke<[email protected]> 写道： 请教一个问题：kafka-per-partition 的watermark的分配，可以在keyby之后分配吗，想做key化的乱序处理能支持吗
