;
>
>
> Besides, the fixed issue you mentioned below will only be occurred in Java
> code calling related API.
>
>
>
> Thanks
>
> Jerry
>
>
>
>
>
> *From:* Antonio Jesus Navarro [mailto:ajnava...@stratio.com]
> *Sent:* Wednesday, October 08, 2014 10:0
10:04 PM
To: user@spark.apache.org
Subject: Error reading from Kafka
Hi, I'm trying to read from Kafka. I was able to do it correctly with this
method.
def createStream(
ssc: StreamingContext,
zkQuorum: String,
groupId: String,
topics: Map[String, Int],
storage
Hi, I'm trying to read from Kafka. I was able to do it correctly with this
method.
def createStream(
ssc: StreamingContext,
zkQuorum: String,
groupId: String,
topics: Map[String, Int],
storageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK_SER_2
): ReceiverInp
