Our Community is getting an upgrade! To get everything ready for the relaunch, we’ll be placing the site in read-only mode starting September 21st.
We really appreciate your understanding while we get things set up behind the scenes. Catch up on all the exciting details about the move here.
Need help or have questions? Drop us a line at [email protected]
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