search

scylladb / kafka-connect-scylladb

Kafka Connect Scylladb Sink
Apache License 2.0
42 stars 22 forks source link

Errorhandling and ssl support #10

Closed patitapaban19 closed 4 years ago

patitapaban19 commented 4 years ago

Added support for the below configs:

  1. behavior.on.error : Error handling behavior setting. Must be configured to one of the following:

    • fail : The Connector throws ConnectException and stops processing records when an error occurs while processing or inserting records into ScyllDB.
    • ignore : Continues to process next set of records when error occurs while processing or inserting records into ScyllDB.
    • log : Logs the error via connect-reporter when an error occurs while processing or inserting records into ScyllDB and continues to process next set of records, available in the kafka topics.

  2. scylladb.ssl.keystore.path : Path to the Java Keystore.

  3. scylladb.ssl.keystore.password : Password to open the Java Keystore with.

  4. scylladb.ssl.cipherSuites : The cipher suites to enable. Defaults to none, resulting in a minimal quality of service according to JDK documentation.

  5. scylladb.ssl.openssl.keyCertChain : Path to the SSL certificate file, when using OpenSSL.

  6. ssl.openssl.privateKey : Path to the private key file, when using OpenSSL.