To address the needs of users who want to customize the kafka-connect-couchbase Sink connector, in version 4.1 we’re planning to add a
SinkHandler extension point, similar to the existing
SourceHandler in the source connector.
The commit that adds the
SinkHandler interface is linked below. (It also incidentally banishes some rare race conditions in the SUBDOCUMENT and N1QL modes).
If this sounds interesting, we’d love to hear your feedback on the new extension point (ideally within the next few weeks while it’s still easy to change).