Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-1715

Add topic routing by field option for New Record State Extraction

XMLWordPrintable

    • Icon: Enhancement Enhancement
    • Resolution: Done
    • Icon: Major Major
    • 1.1.0.Beta1
    • None
    • core-library
    • None

      Currently the New Record State Extraction doesn't support the option of routing based on a certain field from the table. For my current use case I'd need to set a topic based on a varchar field in the table.

      My first attempt was combining ExtractTopic SMT (https://docs.confluent.io/current/connect/transforms/extracttopic.html) with Debezium. This works nicely, except for delete as the `after` struct is null and the SMT fails because it can't set the topic. In case of delete, you'll need to use the field value from the `before` struct while in create / update the `after` struct should be used.

      So my next option was expending the SMT. Based on the existing code for the Outbox Event Router SMT I've added a few lines of code to the SMT which take care of routing for CREATE, UPDATE and DELETE events.

              Unassigned Unassigned
              jhuiting Jos Huiting (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: