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

Realize data distribution according to specified fields

    XMLWordPrintable

Details

    • False
    • None
    • False

    Description

      ID  PRICE  PRODUCT
      –  -----  -------
      1   1.00   APPLE
      2   1.10   APPLE
      3   0.95   BANANA

       

       essentially want the two APPLE rows with IDs 1 and 2 to be in the same partition. want the third row with the BANANA product tag to be placed into a separate partition with all other BANANA events.

       

      I look forward to the official support to set parameters through the connector and specify the field name to realize the function, because I understand that this function is supported in similar tools like canal, but it is just a suggestion, because this requirement is in practical applications Demand is high.
      Similar to my usage as follows
       
        "transforms":"InsertSource",
         "transforms.InsertSource.type":"org.apache.kafka.connect.transforms.InsertField$Value",
          "transforms.InsertSource.static.field":"hdfs_path_tableName",
          "transforms.InsertSource.static.value":"alltablename"
       
      I am very much looking forward to the official support of this function. This function is in great demand in practical applications. thank you very much
       

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              fy18759 fei yang
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: