Re: Dead Letter Queue for FlinkSQL

2025-02-04 Thread Zhanghao Chen
You'll need to implement an custom sink for that. Best, Zhanghao Chen From: Ilya Karpov Sent: Monday, February 3, 2025 18:30 To: user Subject: Dead Letter Queue for FlinkSQL Hi there, Because sink connectors can throw exceptions in real time (for example

Dead Letter Queue for FlinkSQL

2025-02-03 Thread Ilya Karpov
Hi there, Because sink connectors can throw exceptions in real time (for example, due to constraint violation) it's a good practice to have DLQ to continue data processing. Is there any way in FlinkSQL to implement/configure DLQ? Thanks forward!