SASL Authentication Failure while using kafka-connect-couchbase-3.3.0 with Couchbase Server 3.0.1 Community Edition

This happens when the client sends a DCP control the server does not understand. I took another look at the connector code, and I think any version of Couchbase Server >= 3.0.1 should support all of the required controls, but maybe something’s wrong.

I’ll try to reproduce the issue locally. In the mean time, please can you provide the debug log output from the connector ? (add this line to connect-log4j.properties):

log4j.logger.com.couchbase=DEBUG

I’m interested in just the log lines containing “Negotiating DCP Control” so we can see which control the server is choking on.

Thanks,
David