the connection.cluster_address": “127.0.0.1” . I am using it in local . Just to give more background , I am using a dockerized confluent kafka which is pulling the couchbase kafka jar as plugin. confluent provides a REST API to inject configuration to connectors. I am using POST connectors API (http://localhost:18083/connectors) and gave below config to inject
{
“name”: “test-couchbase-source”,
“config”: {
“name”: “test-couchbase-source”,
“connector.class”: “com.couchbase.connect.kafka.CouchbaseSourceConnector”,
“tasks.max”: “2”,
“topic.name”: “test-source”,
“connection.cluster_address”: “127.0.0.1”,
“connection.timeout.ms”: “2000”,
“connection.bucket”: “CentralDB”,
“connection.username”: “Administrator”,
“connection.password”: “password”,
“use_snapshots”:“false”,
“dcp.message.converter.class”: “com.couchbase.connect.kafka.handler.source.DefaultSchemaSourceHandler”,
“event.filter.class”: “com.couchbase.connect.kafka.filter.AllPassFilter”,
“couchbase.stream_from”: “SAVED_OFFSET_OR_BEGINNING”,
“couchbase.compression”: “ENABLED”,
“couchbase.flow_control_buffer”: “128m”,
“couchbase.persistence_polling_interval”: “100ms”
}
}
However the configuration is not getting injected …Am i missing something ?