I'd fix the kafka version on the executor classpath (should be
0.8.2.1) before trying anything else, even if it may be unrelated to
the actual error. Definitely don't upgrade your brokers to 0.9
On Wed, May 25, 2016 at 2:30 AM, Scott W wrote:
> I'm running into below error while trying to consum
I'm running into below error while trying to consume message from Kafka
through Spark streaming (Kafka direct API). This used to work OK when using
Spark standalone cluster manager. We're just switching to using Cloudera
5.7 using Yarn to manage Spark cluster and started to see the below error.
Fe