xtrahotsauce wrote
> I had this same problem as well. I ended up just adding the necessary
> code
> in KafkaUtil and compiling my own spark jar. Something like this for the
> "raw" stream:
>
> def createRawStream(
> jssc: JavaStreamingContext,
> kafkaParams: JMap[String, String],
>
Tathagata Das wrote
> *Answer 1:*Make sure you are using master as "local[n]" with n > 1
> (assuming you are running it in local mode). The way Spark Streaming
> works is that it assigns a code to the data receiver, and so if you
> run the program with only one core (i.e., with local or local[1]),
