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

Support setting a custom delete writemodel strategy

    • Type: Icon: New Feature New Feature
    • Resolution: Fixed
    • Priority: Icon: Unknown Unknown
    • 1.11.0
    • Affects Version/s: None
    • Component/s: Sink
    • Labels:
      None
    • Needed

      Request from the community

      https://www.mongodb.com/community/forums/t/support-for-custom-deletewritemode-strategies-in-kafka-sink/175547

       

      we like to persist has a String-Key and a JSON payload. The id for the MongoDB is part of the JSON payload.  when we receive a tombstone event, we’d like to delete all records that have the key of the topic in a certain field. 

      Currently this is not possible due to -

      1. Writing is not possible, since the connector fails on the first tombstone event and stops afterwards
      2. Delete is not possible, since there is no support for substituting the model for the delete case in a fashion similiar to writemodel.strategy

       

      PR=https://github.com/mongodb/mongo-kafka/pull/108/files

       

            Assignee:
            ross@mongodb.com Ross Lawley
            Reporter:
            robert.walters@mongodb.com Robert Walters
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: