From f4827f1df2284db26d52464082634205ab917a91 Mon Sep 17 00:00:00 2001 From: Damian Guy Date: Mon, 20 Nov 2017 16:32:06 +0000 Subject: [PATCH 1/2] Add doc for fail.on.deserialization.error --- docs/examples.md | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/docs/examples.md b/docs/examples.md index b4a566e31372..025016372f69 100644 --- a/docs/examples.md +++ b/docs/examples.md @@ -304,6 +304,11 @@ Common configuration properties that you might want to change from their default - [cache.max.bytes.buffering](https://kafka.apache.org/documentation/#streamsconfigs): The default value in KSQL is `10000000` (~ 10 MB); +- fail.on.deserialization.error: + When set to true (the default), any errors that occur when deserializing a record will result in the the error being logged and the record being dropped. + If you wish to halt processing on deserialization errors you should set this to false. + + ## Running KSQL From 0e583b0b511241460558c3ef76e1f03aa437e0b9 Mon Sep 17 00:00:00 2001 From: Damian Guy Date: Mon, 20 Nov 2017 17:36:22 +0000 Subject: [PATCH 2/2] update doc --- docs/examples.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/examples.md b/docs/examples.md index 025016372f69..50b30bbe7a0d 100644 --- a/docs/examples.md +++ b/docs/examples.md @@ -305,8 +305,8 @@ Common configuration properties that you might want to change from their default The default value in KSQL is `10000000` (~ 10 MB); - fail.on.deserialization.error: - When set to true (the default), any errors that occur when deserializing a record will result in the the error being logged and the record being dropped. - If you wish to halt processing on deserialization errors you should set this to false. + When set to false (the default), any errors that occur when deserializing a record will result in the the error being logged and the record being dropped. + If you wish to halt processing on deserialization errors you should set this to true.