*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
