Uploaded image for project: 'Couchbase Kafka Connector'
  1. Couchbase Kafka Connector
  2. KAFKAC-80

MutationToken Enabled in Kafka Connector to N1QL at plus

    XMLWordPrintable

    Details

    • Type: New Feature
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 3.1.3
    • Fix Version/s: 3.2.0
    • Labels:

      Description

      In short:

      Goal of this feature is to expose the MutationToken in the Kafka Connector Schema.
      (It could be enabled or not with a parameter such as the SDK => EnableMutationToken)

      So that, we can issue a N1QL query (at_plus) with the MutationToken once the mutation is queued in Kafka. 

      In long, here is scenario example:

      • They have 2 clusters with XDCR. (Cluster_1 & Cluster_2)
      • You write a document with MutationToken enabled on Cluster_1. (EnableMutationToken = True)
      • Once written, you retrieve the Token and run a N1QL at plus with the token => All OK.
      • XDCR replicated the write from Cluster1 to Cluster2.
      • Kafka Connector sends the event to a topic with the mutation.
      • Once received in Kafka, you run a N1QL query at plus on this XDCR write mutation but there is no MutationToken sent by the connector?

        Attachments

        No reviews matched the request. Check your Options in the drop-down menu of this sections header.

          Activity

          Hide
          david.nault David Nault added a comment -

          Kafka message body now includes bucket and vBucketUuid fields which may be used to construct a mutation token.

          Show
          david.nault David Nault added a comment - Kafka message body now includes bucket and vBucketUuid fields which may be used to construct a mutation token.

            People

            • Assignee:
              david.nault David Nault
              Reporter:
              ludovic.dufrenoy Ludovic Dufrenoy
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Gerrit Reviews

                There are no open Gerrit changes

                  PagerDuty

                  Error rendering 'com.pagerduty.jira-server-plugin:PagerDuty'. Please contact your Jira administrators.