This is an automated email from the ASF dual-hosted git repository.
vinoyang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from bd7814d [HUDI-1206] Remove unused variable in Compactor (#1994)
add b883b6d [HUDI-1122] Introduce a kafka implementation of hoodie write
commit ca… (#1886)
No new revisions were added by this update.
Summary of changes:
.../impl/HoodieWriteCommitHttpCallback.java | 13 +-
.../HoodieWriteCommitCallbackUtil.java} | 27 ++--
.../config/HoodieWriteCommitCallbackConfig.java | 13 +-
hudi-utilities/pom.xml | 7 +
.../kafka/HoodieWriteCommitKafkaCallback.java | 141 +++++++++++++++++++++
.../HoodieWriteCommitKafkaCallbackConfig.java | 48 +++++++
.../hudi/utilities/deltastreamer/DeltaSync.java | 8 +-
packaging/hudi-utilities-bundle/pom.xml | 1 +
8 files changed, 232 insertions(+), 26 deletions(-)
copy
hudi-client/src/main/java/org/apache/hudi/callback/{HoodieWriteCommitCallback.java
=> util/HoodieWriteCommitCallbackUtil.java} (57%)
create mode 100644
hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/kafka/HoodieWriteCommitKafkaCallback.java
create mode 100644
hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/kafka/HoodieWriteCommitKafkaCallbackConfig.java
