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