Uploaded image for project: 'Couchbase Kafka Connector'
  1. Couchbase Kafka Connector
  2. KAFKAC-52

add a feature test that ensures SSL configuration

    XMLWordPrintable

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 3.0.0-beta
    • Labels:
      None

      Description

      Please add a feature test to ensure SSL can be configured and used.

      Currently this can be configured by setting environmental properties on com.couchbase.client.core, but this should be easier to configure such that it fits into other frameworks such as Kafka connect. This could be based on the connection string, for instance.

      Sergey Avseyev: Can you add the properties that need to be defined as a workaround?

        Attachments

          Issue Links

          No reviews matched the request. Check your Options in the drop-down menu of this sections header.

            Activity

            Hide
            avsej Sergey Avseyev added a comment -

            For Couchbase Kafka Connector 2.0.1, the main java guide about using SSL could be used: http://developer.couchbase.com/documentation/server/4.5/sdk/java/managing-connections.html

            For example

            DefaultCouchbaseKafkaEnvironment.builder()
                            .kafkaFilterClass("example.SampleFilter")
                            .kafkaTopic("default")
                            .kafkaZookeeperAddress("kafka1.vagrant")
                            .couchbaseNodes("couchbase1.vagrant")
                            .couchbaseBucket("default")
                            .kafkaValueSerializerClass("example.SampleEncoder")
                            .couchbaseStateSerializerClass("example.NullStateSerializer")
                            .dcpEnabled(true)
                            .sslEnabled(true)
                            .sslKeystoreFile("/home/avsej/.keystore")
                            .sslKeystorePassword("password");
            

            Note last three lines.

            Show
            avsej Sergey Avseyev added a comment - For Couchbase Kafka Connector 2.0.1, the main java guide about using SSL could be used: http://developer.couchbase.com/documentation/server/4.5/sdk/java/managing-connections.html For example DefaultCouchbaseKafkaEnvironment.builder() .kafkaFilterClass( "example.SampleFilter" ) .kafkaTopic( "default" ) .kafkaZookeeperAddress( "kafka1.vagrant" ) .couchbaseNodes( "couchbase1.vagrant" ) .couchbaseBucket( "default" ) .kafkaValueSerializerClass( "example.SampleEncoder" ) .couchbaseStateSerializerClass( "example.NullStateSerializer" ) .dcpEnabled( true ) .sslEnabled( true ) .sslKeystoreFile( "/home/avsej/.keystore" ) .sslKeystorePassword( "password" ); Note last three lines.
            Hide
            avsej Sergey Avseyev added a comment -

            For new client the following properties have to be used

            connection.ssl.enabled=true
            connection.ssl.keystore.location=/path/to/keystore
            connection.ssl.keystore.password=TheKeyStorePassword
            

            Show
            avsej Sergey Avseyev added a comment - For new client the following properties have to be used connection.ssl.enabled=true connection.ssl.keystore.location=/path/to/keystore connection.ssl.keystore.password=TheKeyStorePassword

              People

              Assignee:
              avsej Sergey Avseyev
              Reporter:
              ingenthr Matt Ingenthron
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Dates

                Created:
                Updated:
                Resolved:

                  Gerrit Reviews

                  There are no open Gerrit changes

                    PagerDuty