Awesome!
On Wed, Oct 2, 2019 at 3:01 PM Gautam Nayak
wrote:
> Thanks Vinoth for the tip,We were able to fix the issue as our spark
> cluster(2.2.0) bundled both spark-streaming-kafka-0-8 and
> spark-streaming-kafka-0-10 jars. Getting rid of spark-streaming-kafka-0-10
> jars from the cluster
Thanks Vinoth for the tip,We were able to fix the issue as our spark
cluster(2.2.0) bundled both spark-streaming-kafka-0-8 and
spark-streaming-kafka-0-10 jars. Getting rid of spark-streaming-kafka-0-10 jars
from the cluster resolved the ClasscastException.
On Oct 1, 2019, at 10:25 AM, Vinoth
Thanks for the detailed notes. helps.
Could you give a quick shot trying to override the version in a custom
build ?
Wondering if just upgrading Kafka would suffice for your scenario (without
needing the 2.12 scala bundle)
On Tue, Oct 1, 2019 at 10:14 AM Gautam Nayak
wrote:
> Thanks Nishith
