Support Questions

Find answers, ask questions, and share your expertise

Issue in importing kafka_serializer.StringDecoder


In my project I need to use Kafka ad Spark streaming for doing real time analytics. So I am trying to import Kafka and Spark streaming dependencies. In order to read the Kakfa topics in my spark streaming program, I am trying to import kafka.serializer.StringDecoder. But I am not able to import it.screen-shot-2018-11-05-at-51111-pm.png

Even I wrote a dummy program to fix this issue. But still I couldn't find a solution.



I could fix this issue by adding "import _root_.kafka.serializer.StringDecoder" in my imports. I attached the screen shot of the my code.


Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.