Hi @somant    Please don't use open source libraries and use cluster-supported spark/kafka versions.    Check the following example code:   https://community.cloudera.com/t5/Community-Articles/Running-DirectKafkaWordCount-example-in-CDP/ta-p/340402 ... View more