This is an automated email from the ASF dual-hosted git repository.
yihua pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from cf119ccf0e5 [HUDI-7462] Refactor checkTopicCheckpoint in
KafkaOffsetGen for reusability (#10794)
add bcb3807d90f [HUDI-7464] Fix minor bugs in kafka post-processing
related code (#10772)
No new revisions were added by this update.
Summary of changes:
.../utilities/schema/KafkaOffsetPostProcessor.java | 35 ++++++++----
.../hudi/utilities/sources/JsonKafkaSource.java | 4 +-
.../schema/TestKafkaOffsetPostProcessor.java | 65 ++++++++++++++++++++++
.../utilities/sources/TestJsonKafkaSource.java | 3 +
4 files changed, 94 insertions(+), 13 deletions(-)
create mode 100644
hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/TestKafkaOffsetPostProcessor.java