This is an automated email from the ASF dual-hosted git repository.
vinoth pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from 46f0496 [MINOR] Fix typo,'intance' corrected to 'instance' (#3788)
add 3686c25 [HUDI-2469] [Kafka Connect] Replace json based payload with
protobuf for Transaction protocol. (#3694)
No new revisions were added by this update.
Summary of changes:
hudi-kafka-connect/demo/setupKafka.sh | 4 +-
hudi-kafka-connect/pom.xml | 26 +++
.../org/apache/hudi/connect/HoodieSinkTask.java | 9 +-
.../connect/kafka/KafkaConnectControlAgent.java | 56 ++---
.../hudi/connect/kafka/KafkaControlAgent.java | 4 +-
.../hudi/connect/kafka/KafkaControlProducer.java | 38 +---
.../transaction/ConnectTransactionCoordinator.java | 71 +++---
.../transaction/ConnectTransactionParticipant.java | 56 +++--
.../hudi/connect/transaction/ControlEvent.java | 237 ---------------------
.../hudi/connect/transaction/CoordinatorEvent.java | 8 +-
.../transaction/TransactionCoordinator.java | 4 +-
.../transaction/TransactionParticipant.java | 8 +-
.../hudi/connect/utils/KafkaConnectUtils.java | 40 +++-
.../connect/writers/AbstractConnectWriter.java | 4 +-
.../connect/writers/BufferedConnectWriter.java | 4 +-
.../apache/hudi/connect/writers/ConnectWriter.java | 2 +-
.../hudi/connect/writers/KafkaConnectConfigs.java | 1 +
.../src/main/resources/ControlMessage.proto | 65 ++++++
.../src/main/resources/log4j.properties | 0
.../connect/TestConnectTransactionCoordinator.java | 65 +++---
.../connect/TestConnectTransactionParticipant.java | 71 +++---
.../apache/hudi/helper/MockKafkaControlAgent.java | 8 +-
packaging/hudi-kafka-connect-bundle/pom.xml | 9 +
pom.xml | 2 +
24 files changed, 331 insertions(+), 461 deletions(-)
delete mode 100644
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/ControlEvent.java
create mode 100644 hudi-kafka-connect/src/main/resources/ControlMessage.proto
copy {hudi-client/hudi-spark-client =>
hudi-kafka-connect}/src/main/resources/log4j.properties (100%)
