spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kiran Biswal <>
Subject class KafkaCluster related errors
Date Sun, 06 Jun 2021 19:57:51 GMT
*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.


View raw message