Silver ⭐️⭐️

Solved

Connect to kerberos authenticated schema registry using Python Library python-schema-registry-client

3 replies
5013 views
Translate All

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

TimothySpannAnswer

Platinum ⭐️⭐️⭐️

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.

Platinum ⭐️⭐️⭐️

Cloudera Schema Registry is rarely on 8081

It is usually on port 9090.

https://docs.cloudera.com/csp/2.0.1/schema-registry-overview/topics/csp-examples_of_interacting_with_schema_registry.html

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

Translate

TimothySpannAnswer

Platinum ⭐️⭐️⭐️

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.

Translate

Pr1Author

Silver ⭐️⭐️

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

Translate