How can I solve this Python error : ImportError cannot import name KafkaProducer

I have a very strange problem. I wrote a spark streaming job that monitor an HDFS directory, reads the newly added files, and send the file content to Kafka. When submitting the job I got that error ImportError: cannot import name KafkaProducer Wh...