Created 02-09-2021 06:46 AM
Hello ,
We have one use case where we need to connect to HDF schema registry using Python Library .
We have installed python-schema-registry-client library.
But Schema registry URL is kerberos authenticated URL so couldn't connect with
below code
from schema_registry.client import SchemaRegistryClient, schema
client = SchemaRegistryClient(url="http://127.0.0.1:8081")
provided here https://marcosschroh.github.io/python-schema-registry-client/
Getting Authentication error 401.
Is there any extra arguments or methods to get connect to Schema registry using python library?
Thanks and Regards
Created 02-09-2021 01:05 PM
That Python is for the Confluent Schema Registry.
I was able to connect, but Confluent supports their own Avro schema format.
This was my example and it worked:
from schema_registry.client import SchemaRegistryClient, schema
client = SchemaRegistryClient(url="http://myclouderasr.com:7788")
print( client.get_schema('weatherny') )
This library doesn't seem to support logins or security.
Created 02-09-2021 08:46 AM
Cloudera Schema Registry is rarely on 8081
It is usually on port 9090.
Which version are you using? Which form factor? Public Cloud? On-Premise?
https://www.datainmotion.dev/2020/10/running-flink-sql-against-kafka-using.html
https://www.datainmotion.dev/2020/05/commonly-used-tcpip-ports-in-streaming.html
https://www.datainmotion.dev/2020/06/using-apache-kafka-using-cloudera-data.html
https://www.datainmotion.dev/2020/08/deleting-schemas-from-cloudera-schema.html
Check out the swagger rest docs
https://www.datainmotion.dev/2020/11/flank-smart-weather-websocket.html
Created 02-09-2021 01:05 PM
That Python is for the Confluent Schema Registry.
I was able to connect, but Confluent supports their own Avro schema format.
This was my example and it worked:
from schema_registry.client import SchemaRegistryClient, schema
client = SchemaRegistryClient(url="http://myclouderasr.com:7788")
print( client.get_schema('weatherny') )
This library doesn't seem to support logins or security.
Created 02-11-2021 01:19 AM
Thanks Spann for useful links and information about python-schema-registry-client library.
So now I can see one of possible way to connect to kerberos Schema registry URL through python is requests_kerberos library.
Thanks and Regards