search

confluentinc / confluent-kafka-python

Confluent's Kafka Python Client
http://docs.confluent.io/current/clients/confluent-kafka-python
Other
84 stars 892 forks source link

Pickle KafkaException #1749

Open Hawool opened 4 months ago

Hawool commented 4 months ago

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)

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