confluent-kafka-python
confluent-kafka-python copied to clipboard
Enable pickling of schema registry client by updating `_SchemaCache`
- Mirrors PR 56 in
python-schema-registry-client - Attempted to use
AvroSerialzerandAvroDeserializerwithin pyspark udfs to (un)serialize contents of a dataframe but ran intoTypeError: cannot pickle '_thread.lock' object - The serializers are dependent on
SchemaRegistryClient, which in turn uses_SchemaCache - Added
__setstate__and__getstate__methods to process the.lockattribute of_SchemaCache
Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you all sign our Contributor License Agreement before we can accept your contribution.
0 out of 2 committers have signed the CLA.
:x: Jonathan Leung
:x: jkleung11
Jonathan Leung seems not to be a GitHub user. You need a GitHub account to be able to sign the CLA. If you have already a GitHub account, please add the email address used for this commit to your account.
You have signed the CLA already but the status is still pending? Let us recheck it.