Just recently we released the first GA version of Couchbase Kafka Connector. It provides functionality to direct stream of events from Couchbase Server (3.0 or later) to Kafka. More info is on the documentation page. Its issue tracker is located on our JIRA.
Note that the interface the connector is using at Couchbase Server is experimental at the moment, but on a track to be supported soon.
Getting it
You can find the project source code on github. The developer previews were available through our own maven repository, the GA artifacts are available on maven central. Here are the coordinates:
Group ID: com.couchbase.client
Artifact ID: kafka-connector
Version: 1.0.0
If you are using gradle, paste this to your build.gradle:
1 2 3 |
dependencies { compile(group: 'com.couchbase.client', name: 'kafka-connector', version: '1.0.0') } |
For maven POM files:
1 2 3 4 5 6 7 |
<dependencies> <dependency> <groupId>com.couchbase.client</groupId> <artifactId>kafka-connector</artifactId> <version>1.0.0</version> </dependency> </dependencies> |
Please post any feedback here or to the Couchbase Forums!