text: #
  # Licensed to the Apache Software Foundation (ASF) under one or more
  # contributor license agreements.  See the NOTICE file distributed with
  # this work for additional information regarding copyright ownership.
  # The ASF licenses this file to You under the Apache License, Version 2.0
  # (the "License"); you may not use this file except in compliance with
  # the License.  You may obtain a copy of the License at
  #
  #    http://www.apache.org/licenses/LICENSE-2.0
  #
  # Unless required by applicable law or agreed to in writing, software
  # distributed under the License is distributed on an "AS IS" BASIS,
  # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  # See the License for the specific language governing permissions and
  # limitations under the License.
  #
  
  # Borrowed from https://github.com/aseigneurin/kafka-tutorial-simple-client/blob/master/src/main/resources/register_schema.py
  
  import os
  import sys
  
  import requests
  
  schema_registry_url = sys.argv[1]
  topic = sys.argv[2]
  schema_file = sys.argv[3]
  
  aboslute_path_to_schema = os.path.join(os.getcwd(), schema_file)
  
  print("Schema Registry URL: " + schema_registry_url)
  print("Topic: " + topic)
  print("Schema file: " + schema_file)
  print
  
  with open(aboslute_path_to_schema, 'r') as content_file:
      schema = content_file.read()
  
  payload = "{ \"schema\": \"" \
            + schema.replace("\"", "\\\"").replace("\t", "").replace("\n", "") \
            + "\" }"
  print("Payload: " + payload)
  
  url = schema_registry_url + "/subjects/" + topic + "-value/versions"
  headers = {"Content-Type": "application/vnd.schemaregistry.v1+json"}
  
  r = requests.post(url, headers=headers, data=payload)
  if r.status_code == requests.codes.ok:
      print("Success")
  else:
      r.raise_for_status()