You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by le...@apache.org on 2021/06/28 13:55:25 UTC

[hudi] branch master updated (34fc8a8 -> 039aeb6)

This is an automated email from the ASF dual-hosted git repository.

leesf pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.


    from 34fc8a8  [HUDI-2067] Sync FlinkOptions config to FlinkStreamerConfig (#3151)
     add 039aeb6  [HUDI-1910] Commit Offset to Kafka after successful Hudi commit (#3092)

No new revisions were added by this update.

Summary of changes:
 .../utilities/callback/SourceCommitCallback.java   | 18 +++---
 .../hudi/utilities/deltastreamer/DeltaSync.java    |  2 +-
 .../deltastreamer/SourceFormatAdapter.java         |  4 ++
 .../hudi/utilities/sources/AvroKafkaSource.java    | 10 +++
 .../hudi/utilities/sources/JsonKafkaSource.java    | 10 +++
 .../org/apache/hudi/utilities/sources/Source.java  |  3 +-
 .../utilities/sources/helpers/KafkaOffsetGen.java  | 51 +++++++++++----
 .../hudi/utilities/sources/TestKafkaSource.java    | 73 +++++++++++++++++++++-
 8 files changed, 144 insertions(+), 27 deletions(-)
 copy hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/replication/HiveSyncGlobalCommit.java => hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/SourceCommitCallback.java (69%)