Help with couchbase kafka connector

[tkeble]

Hi,

Trying to extend out of the java sdk category - Is anyone able to help with this post from a few days ago please?

Couchbase kafka-connector environments

Hi, We have been implementing a solution using the couchbase-kafka-connector, and have been eagerly awaiting the next release after 1.0.0. I have just upgraded to 1.1.0, and found that the static methods for creation of the CouchbaseKafkaConnector class have changed quite significantly, causing some problems. In version 1.0.0 the main way of creating a connector was: CouchbaseKafkaConnector connector = CouchbaseKafkaConnector.create(DefaultCouchbaseKafkaEnvironment environment, String couchba…

Cheers,
Tom