Couchbase entry updatation would trigger streaming in KAFKA as a producer

Java SDK
,
1

Hi Guys,

I have an interesting feature in my hand to develop. We have a batch job which updates entries in CB. I need to push some data on KAFKA topic upon update of the entries. Here the approach will be as a producer for the KAFKA topic and our CB is not indexed so N1QL query, only Java SDK in scope.

Any pointers/sample in this area will be really appreciated.

Thanks,
Tanmoy

2

Hi Tanmoy,

Check out the Couchbase Kafka connector. It’s a plugin for the Kafka Connect framework that lets you publish messages to a Kafka topic whenever a Couchbase document changes.

Cheers,
David