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.