Couchbase Kafka connector 3.4.8

Kafka Connector
,
1

Hi Team,

I am trying to implement couchbase kafka connector with single node Kafka cluster, zookeeper and Couch server 6.5.

I get issue while following document here: https://docs.couchbase.com/kafka-connector/current/quickstart.html

While I start the kafka connector source in standalone mode, I see error below.

Caused by: com.couchbase.client.deps.com.fasterxml.jackson.databind.exc.InvalidFormatException: Can not construct instance of com.couchbase.client.core.config.BucketCapabilities from String value (“durableWrite”): value not one of declared Enum instance names: [nodesExt, dcp, cbhello, xattr, couchapi, cccp, touch, xdcrCheckpointing]

Caused by: com.couchbase.client.deps.com.fasterxml.jackson.databind.exc.InvalidFormatException: Can not construct instance of com.couchbase.client.core.config.BucketCapabilities from String value (“durableWrite”): value not one of declared Enum instance names: [nodesExt, dcp, cbhello, xattr, couchapi, cccp, touch, xdcrCheckpointing]
at [Source: {“rev”:41,“name”:“travel-sample”,“uri”:"/pools/default/buckets/travel-sample?bucket_uuid=2395f1bca573d100977f9adaf60634c0",“streamingUri”:"/pools/default/bucketsStreaming/travel-sample?bucket_uuid=2395f1bca573d100977f9adaf60634c0",“nodes”:[{“couchApiBase”:“http://127.0.0.1:8092/travel-sample%2B2395f1bca573d100977f9adaf60634c0",“hostname”:“127.0.0.1:8091”,“ports”:{“direct”:11210}}],“nodesExt”:[{“services”:{“mgmt”:8091,“mgmtSSL”:18091,“cbas”:8095,“cbasSSL”:18095,“eventingAdminPort”:8096,“eventingDebug”:9140,“eventingSSL”:18096,“fts”:8094,“ftsSSL”:18094,“ftsGRPC”:9130,“ftsGRPCSSL”:19130,“indexAdmin”:9100,“indexScan”:9101,“indexHttp”:9102,“indexStreamInit”:9103,“indexStreamCatchup”:9104,“indexStreamMaint”:9105,“indexHttps”:19102,“kv”:11210,“kvSSL”:11207,“capi”:8092,“capiSSL”:18092,“projector”:9999,“projector”:9999,“n1ql”:8093,“n1qlSSL”:18093},“thisNode”:true}],“nodeLocator”:“vbucket”,“uuid”:“2395f1bca573d100977f9adaf60634c0”,“ddocs”:{“uri”:"/pools/default/buckets/travel-sample/ddocs"},“vBucketServerMap”:{“hashAlgorithm”:“CRC”,“numReplicas”:1,“serverList”:[“127.0.0.1:11210”],“vBucketMap”:[[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1],[0,-1]]},“bucketCapabilitiesVer”:"",“bucketCapabilities”:[“durableWrite”,“couchapi”,“dcp”,“cbhello”,“touch”,“cccp”,“xdcrCheckpointing”,“nodesExt”,“xattr”],“clusterCapabilitiesVer”:[1,0],“clusterCapabilities”:{“n1ql”:["enhancedPreparedStatements”]}}; line: 1, column: 1601] (through reference chain: com.couchbase.client.core.config.DefaultCouchbaseBucketConfig[“bucketCapabilities”]->java.util.ArrayList[0])

Couchbase Kafka connector version: 3.4
Kafka version: 2.12-2.5.0

I suppose the problem is with enum definition in core-io.jar.

1 Like
2

Hi Santhosh,

That sure looks like a bug. Thanks for the detailed report. I’ve filed it as KAFKAC-174.

Let me take a look and see if we can get this into next week’s release.

Thanks,
David

3

Hi Santhosh,

The issue you describe was originally filed as JVMCBC-510 and fixed a long time ago.

Can you try upgrading to connector version 3.4.8?

If that doesn’t resolve the issue, I’d check whether there could possibly be an old version of the connector installed somewhere in Kafka’s lib directory, or somewhere else in the class path.

Thanks,
David