The problem is that kafka gets imported via "import
org.apache.spark.streaming._", and "import kafka.serializer.StringDecoder"
fails. You should remove the first line and only import the classes you
need.

On Fri, Jul 10, 2015 at 8:13 PM, Ignacio Alvarez <ignacioalv...@gmail.com>
wrote:

> Hi guys,
>
> does Zeppelin support writing Spark Streaming applications consuming from
> Kafka?
>
> I tried importing the Kafka dependency directly as in the twitter tutorial
> but it didn't get recognized. I though i'd ask before checking further:
>
> [image: Inline image 1]
> Thanks,
>
> Ignacio
>

Reply via email to