To configure the Couchbase Sink Kafka Connector to disregard errors and proceed with the operation, add the following configuration properties:
errors.tolerance
: set this to "all" to indicate that all errors should be tolerated.errors.log.enable
: set this to "true" to enable logging of errors.errors.deadletterqueue.topic.name
: set this to the name of the topic to which failed messages should be sent.Here is an example of how to configure the Couchbase Sink Kafka Connector to ignore errors:
name=couchbase-sink
tasks.max=1
connector.class=com.couchbase.connect.kafka.CouchbaseSinkConnector
topics=test-topic
couchbase.seed.nodes=localhost
couchbase.bucket=test
couchbase.username=test
couchbase.password=test
errors.tolerance=all
errors.log.enable=true
errors.deadletterqueue.topic.name=failed-messages
Please start posting anonymously - your entry will be published after you log in or create a new account. This space is reserved only for answers. If you would like to engage in a discussion, please instead post a comment under the question or an answer that you would like to discuss
Asked: 2021-07-06 11:00:00 +0000
Seen: 8 times
Last updated: Feb 01 '23
What does "Couchbase URL error unauthorized: password required" mean?
What does the error message "unauthorized: password required" mean in relation to the Couchbase URL?
What distinguishes HBase from Hadoop and HDFS?
What distinguishes HBase from Hadoop/HDFS?
What is the proper method of resetting the API state in RTK Query?
In what situations should Hadoop, HBase, Hive, and Pig be employed?
What is the process to modify the default language of an Android application?
What is the procedure for managing csrf in RTK Query? What is the method to obtain the XSRF-token?