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

Allow Source connector to split DCP stream and write into separate topics

    XMLWordPrintable

    Details

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

      Description

      From the user perspective it should be extension class, which implements decision logic based on the mutation event from the DCP stream.

      The state will be still associated with the partitions in the source stream.

        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 -

          The user can now specify a custom `SourceHandler` implementation that can route the message.

          (Actually, prior to this change the user could do the same thing with a custom `Converter` implementation, but it took a bit more work.)

          Show
          david.nault David Nault added a comment - The user can now specify a custom `SourceHandler` implementation that can route the message. (Actually, prior to this change the user could do the same thing with a custom `Converter` implementation, but it took a bit more work.)

            People

            • Assignee:
              david.nault David Nault
              Reporter:
              avsej Sergey Avseyev
            • Votes:
              0 Vote for this issue
              Watchers:
              2 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.