From f230eca9b5a02d68788875be78c142aa10522fc3 Mon Sep 17 00:00:00 2001 From: Y Ethan Guo Date: Mon, 10 Jan 2022 13:07:52 -0800 Subject: [PATCH] [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 c75b4a931..5c618b2a7 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