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

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