Comment by Kevin on "How can I solve this Python error : ImportError cannot import name KafkaProducer"

Anas Rabei

Java to the end :)

Unfortunately, I got the error in line 6 :(. Also as I mentioned, I can import Kafkaproducer normally in the python and pyspark shell.

Kevin

i write code

@fanooos That most likely means that the kafka package isn't installed correctly on the machine. How did you install it?

Anas Rabei

Java to the end :)

pip install kafka-python

Anas Rabei

Java to the end :)

Kevin

i write code

that could very well be the issue. You can see what is available in the REPL by doing import kafka dir(kafka)

Search Hashnode