lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fix port number in setupKafka.sh (#4546)

Browse Source
This commit is contained in:
Y Ethan Guo
2022-01-10 13:07:52 -08:00
committed by GitHub
parent 7a8b94c82d
commit f230eca9b5
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-kafka-connect/demo/setupKafka.sh
View File

@@ -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