spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kiran Biswal <biswalki...@gmail.com>
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*
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

Mime
View raw message