Uploaded image for project: 'Kafka Connector'
  1. Kafka Connector
  2. KAFKA-51

MongoDB Event Roundtrip

XMLWordPrintableJSON

    • Type: Icon: New Feature New Feature
    • Resolution: Fixed
    • Priority: Icon: Major - P3 Major - P3
    • 1.4.0
    • Affects Version/s: None
    • Component/s: None
    • Labels:
      None
    • Needed
    • Hide

      Notes from Robert:
      For the sink CDC docs, set: change.data.capture.handler=com.mongodb.kafka.connect.sink.cdc.mongodb.ChangeStreamHandler
      Build is here: https://oss.sonatype.org/content/repositories/snapshots/org/mongodb/kafka/mongo-kafka[…]NAPSHOT/mongo-kafka-connect-1.4.0-20210121.161627-13-all.jar

      This is 1 of 2 key features for 1.4 release (approx first week of Feb)

      Show
      Notes from Robert: For the sink CDC docs, set: change.data.capture.handler=com.mongodb.kafka.connect.sink.cdc.mongodb.ChangeStreamHandler Build is here: https://oss.sonatype.org/content/repositories/snapshots/org/mongodb/kafka/mongo-kafka[ …]NAPSHOT/mongo-kafka-connect-1.4.0-20210121.161627-13-all.jar This is 1 of 2 key features for 1.4 release (approx first week of Feb)

      Support for CDC based on MongoDB Change Events

      When using MongoDB as a source for a certain topic, the Change Events of the topic should be added into the target in CDC mode, similar to the CDC handling of the existing Debezium implementation.

      A prototype is available in branch mongo_cdc here:

      This feature allows to replicate all changes of a database into another one. Use cases can be: 1:1 replication of master data between different services; DR into a totally separate MongoDB cluster; partial replication into other MongoDB clusters; and more.

            Assignee:
            chris.cho@mongodb.com Christopher Cho
            Reporter:
            christian.kurze@mongodb.com Christian Kurze (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            9 Start watching this issue

              Created:
              Updated:
              Resolved: