Configure error handling
Specifies whether Kafka Connector should continue processing records even if an error occurred.
cassandra-sink-distributed.json.sample
- The cassandra-sink-distributed.json.sample file is located in the conf directory of the DataStax Apache Kafka Connector distribution package.
cassandra-sink-standalone.properties.sample
- The cassandra-sink-standalone.properties.sample file is located in the conf directory of the DataStax Apache Kafka Connector distribution package.
DataStax Apache Kafka™ Connector provides an optional parameter,
ignoreErrors
. When set to true
, it allows the
connector to continue processing records even after an error occurred on the prior
record.
- ignoreErrors
- Use
ignoreErrors
settings to ignore specific types or all runtime errors, depending on the setting you choose.
If you setValue Meaning Notes false
No errors are ignored Deprecated - equivalent to NONE
true
Only driver errors are ignored Deprecated - equivalent to DRIVER
NONE
No errors are ignored; default behavior ALL
All errors are ignored DRIVER
Only driver errors are ignored ignoreErrors
to any value other thanfalse
, any erroneous record is logged once and the next record is picked up by the Kafka Connector automatically.