Dead-letter-queue

Flink SQL 没有内置通用的 DLQ 语法，采用 Raw Source 读取原始消息、SQL 层容错解析、双路分流到业务 Sink 和 DLQ Topic 的方案。