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

Correct documentation of Event Router in expand.json mode

XMLWordPrintable

    • False
    • None
    • False

      Documentation

      Which use case/requirement will be addressed by the proposed feature?

      According to documentation for Debezium 1.9/2.0+, Event Router documentation(Expanding escaped JSON String as JSON paragraph) contains incorrect information:

       

      To enable this transformation, you have to set the table.expand.json.payload to true and use the StringConverter like below:

transforms=outbox,...
transforms.outbox.type=io.debezium.transforms.outbox.EventRouter
transforms.outbox.table.expand.json.payload=true
value.converter=org.apache.kafka.connect.storage.StringConverter

      But according to zulip conversation with jpechane, we found incorrectness of the documentation.

       

      Implementation ideas (optional)

      The documentation section should be corrected to:

      To enable this transformation, you have to set the table.expand.json.payload to true and use the JsonConverter like below:

transforms=outbox,... 
transforms.outbox.type=io.debezium.transforms.outbox.EventRouter 
transforms.outbox.table.expand.json.payload=true 
value.converter=org.apache.kafka.connect.json.JsonConverter

       
       
       

       

              Unassigned Unassigned
              mdubrovin Mikhail Dubrovin (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated:
                Resolved: