Hi Sunfulin, I think this is very important too. There is an issue to fix this[1]. Is that meet your requirement?
[1] https://issues.apache.org/jira/browse/FLINK-15396 Best, Jingsong Lee On Mon, Mar 9, 2020 at 12:33 PM sunfulin <sunfulin0...@163.com> wrote: > hi , community, > I am wondering if there is some config params with error handler strategy > as [1] refers when defining a Kafka stream table using Flink SQL DDL. For > example, the following `json.parser.failure.strategy' can be set to > `silencly skip` that can skip the malformed dirty data process while > consuming kafka records. > > create table xxx ( > ... > ) with ( > 'connector.type' = 'kafka', > 'format.type' = 'json', > 'json.parser.failure.strategy' = 'silencly skip' > ) > [1] > https://www.confluent.io/blog/kafka-connect-deep-dive-error-handling-dead-letter-queues/ > > > > -- Best, Jingsong Lee
