I am using spark 3.0.1 AND Kafka 0.10 AND Scala 2.12. Getting an error related to KafkaCluster (not found: type KafkaCluster). Is this class deprecated? How do I find a replacement?

I am upgrading from spark 2.0.1 to spark 3.0.1

In spark 2.0.1 KafkaCluster was supported
https://spark.apache.org/docs/2.0.1/api/java/org/apache/spark/streaming/kafka/KafkaCluster.html

just looking for ideas how to achieve same functionality in spark 3.0.1. Any thoughts and examples will be highly appreciated.

Thanks
Kiran