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/
