Yizhou-Yang opened a new pull request, #7924:
URL: https://github.com/apache/inlong/pull/7924
### Prepare a Pull Request
- Fixes #7900
### Motivation
See issue.
### Modifications
Added PrimaryKeyPartitioner, and made modifications to support upsert-kafka
### Verifying this change
1. executing the sql in the issue again
2. create a kafka-mysql task to consume all the messages back to mysql
![Uploading Pasted Graphic 14.png…]()
the mysql table fluctuated from 1000-2000 rows, and in the end it redeced to
0 rows, so I assume that the issue has been solved. The format used is json,
for canal-json/avro/csv, I only tested that the primaryKey partitition is in
effect and there are no errors.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
