How to connect Apache kafka to couchbase by couchbase connector



Hello every one,
I tried to understand this Tutorial but it isn’t clear.
I’m gonna sink kafka with couchbase.

I’ll appreciate if any one assists me.

Issue on couchbase-kafka-sink-connector implementing

Any specific question? Or do you have any errors in the logs?


Thanks, many thanks for quick reply.
I need a more complete document to how to sink Kafka to Couchbase.
that document is very short.
I tired to did that, let me explain:
I tried to use Apache Kafka:

  1. download,
  2. copy etc/kafka-connect-couchbase/ files to kafka_2.12-
  3. copy share/java/ files to kafka_2.12-
    and when tired to run I encountred some error regarding avro.
    actually, I tried that with confluent too:
  4. download confluent-oss-3.2.2-2.11.tar.gz and extract.
  5. copy etc/kafka-connect-couchbase/ files to etc/
  6. copy share/java/ files to /share/java
  7. try: bin/ config/ config/_
  8. config is:


and I encountred some error those I’m on them. :slight_smile:


What are the errors? I set this up just last week and I noticed that some of the paths have changed, but I was able to set it up just fine.

With confluent-3.2.2, here’s the layout I used to conform to their path:

ingenthr-mbp:confluent-3.2.2 ingenthr$ find . -type d -name '*couchbase*' |xargs find


Sorry, may be I could not explain my issue completely(sorry for my English).
I need a good and complete document, the document that I mentioned at the top, it told you could use Apache Kafka directly, but there is not enough guidance.
on the other hand, when I checked log file, I guessed we need some Avro configuration that did not mention in that Doc.