Error creating CouchbaseKafkaConnector instance

https://github.com/couchbase/couchbase-kafka-connector/issues/9

Apologies if duplicate. If fixed, please close bug on Github.

msomolinos commented on Jan 5
Hello,

When I run this code, an unexpected exception suddenly appear.

My code:

val builder = DefaultCouchbaseKafkaEnvironment.builder().kafkaFilterClass(prop.getProperty("kafka.cb.filter"))
.kafkaValueSerializerClass(prop.getProperty("kafka.cb.encoder"))
.dcpEnabled(true).asInstanceOf[DefaultCouchbaseKafkaEnvironment.Builder]
val env = builder.build()
val connector = CouchbaseKafkaConnector.create(
List(prop.getProperty("db.couchbase.hosts")).asJava, prop.getProperty("kafka.cb.bucket"),
prop.getProperty("kafka.cb.password"), prop.getProperty("kafka.cb.zkHost"), prop.getProperty("kafka.cb.topic"),
env)
Exception trace:

INFO - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=4000 watcher=org.I0Itec.zkclient.ZkClient@40fc38e0
INFO - Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
INFO - Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session
INFO - Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x151aa158c290056, negotiated timeout = 6000
INFO - zookeeper state changed (SyncConnected)
Exception in thread "main" java.lang.NoSuchMethodError: java.lang.String.join(Ljava/lang/CharSequence;Ljava/lang/Iterable;)Ljava/lang/String;
at com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.dumpParameters(DefaultCouchbaseKafkaEnvironment.java:226)
at com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment.toString(DefaultCouchbaseKafkaEnvironment.java:234)
at com.couchbase.client.core.CouchbaseCore.<init>(CouchbaseCore.java:141)
at com.couchbase.kafka.CouchbaseKafkaConnector.<init>(CouchbaseKafkaConnector.java:121)
at com.couchbase.kafka.CouchbaseKafkaConnector.create(CouchbaseKafkaConnector.java:206)
sbt dependencies:

"com.couchbase.client" % "kafka-connector" % "1.2.1"
JVM:

java.version=1.7.0_79
Is there any problem with JVM compatibilty? Current DefaultCouchbaseKafkaEnvironment version contains next line:

class: com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
line: 226
sb.append(", couchbaseNodes=").append(String.join(",", this.couchbaseNodes));
This method works using JAVA 8 JVM version, but it is not compatible with previous JVM versions. A backward compatible code could be:

class: com.couchbase.kafka.DefaultCouchbaseKafkaEnvironment
sb.append(", couchbaseNodes=").append(java.util.Arrays.deepToString(this.couchbaseNodes.toArray()));
Thanks,

Best regards,

Manu