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

Posted to commits@hudi.apache.org by si...@apache.org on 2022/01/11 05:31:41 UTC

[hudi] 05/06: [MINOR] Fix port number in setupKafka.sh (#4546)

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

sivabalan pushed a commit to branch release-0.10.1-rc1
in repository https://gitbox.apache.org/repos/asf/hudi.git

commit 44a85c7ab04fe32aea7ed492d2d9fa3e546c0d94
Author: Y Ethan Guo <et...@gmail.com>
AuthorDate: Mon Jan 10 13:07:52 2022 -0800

    [MINOR] Fix port number in setupKafka.sh (#4546)
---
 hudi-kafka-connect/demo/setupKafka.sh | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hudi-kafka-connect/demo/setupKafka.sh b/hudi-kafka-connect/demo/setupKafka.sh
index c75b4a9..5c618b2 100755
--- a/hudi-kafka-connect/demo/setupKafka.sh
+++ b/hudi-kafka-connect/demo/setupKafka.sh
@@ -130,7 +130,7 @@ fi
 # Setup the schema registry
 export SCHEMA=$(sed 's|/\*|\n&|g;s|*/|&\n|g' ${schemaFile} | sed '/\/\*/,/*\//d' | jq tostring)
 curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" --data "{\"schema\": $SCHEMA}" http://localhost:8082/subjects/${kafkaTopicName}/versions
-curl -X GET http://localhost:8081/subjects/${kafkaTopicName}/versions/latest
+curl -X GET http://localhost:8082/subjects/${kafkaTopicName}/versions/latest
 
 # Generate kafka messages from raw records
 # Each records with unique keys and generate equal messages across each hudi partition