Hello
I'm trying to connect kafka in spark shell, but failed as below. Could you
take a look what I missed.
scala> val kafkaStream = KafkaUtils.createStream(ssc,
"test-vip.snc1:2181", "test_spark", Map("user-test"->1))
error: bad symbolic reference. A signature in KafkaUtils.class refers to
term serializer
in value kafka which is not available.
It may be completely missing from the current classpath, or the version on
the classpath might be incompatible with the version used when compiling
KafkaUtils.class.
Thanks
Gary
