You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Description
Can't pickle KafkaException, wrong import. When i use celery, and celery use pickle to serialization, i get this error:
''PicklingError("Can't pickle <class 'cimpl.KafkaException'>: import of module 'cimpl' failed")''
How to reproduce
import pickle
import confluent_kafka
e = confluent_kafka.KafkaException()
pickle.dumps(e)
Description
Can't pickle KafkaException, wrong import. When i use celery, and celery use pickle to serialization, i get this error:
''PicklingError("Can't pickle <class 'cimpl.KafkaException'>: import of module 'cimpl' failed")''
How to reproduce
Result:
_pickle.PicklingError: Can't pickle <class 'cimpl.KafkaException'>: import of module 'cimpl' failed
Also i tried with confluent_kafka.cimpl.KafkaException() and confluent_kafka.error.KafkaException(), and got the same result.
Checklist
The text was updated successfully, but these errors were encountered: