couchbaselabs / flink-connector-couchbase

Experimental Flink connector for Couchbase.

Version Matrix

Flink Connector for Couchbase

Experimental. Unsupported. Great plans for the future.

Maven Coordinates:

<dependency>
    <groupId>com.couchbase.client</groupId>
    <artifactId>flink-connector-couchbase_${scalaBinaryVersion}</artifactId>
    <version>${connectorVersion}</version>
</dependency>

${scalaBinaryVersion} = 2.11 or 2.12, depending on the flavor of Flink you're using.

${connectorVersion} = the version of this connector. See the git tags for valid values.


The example directory contains an example of how to use the connector.