This message was deleted.
# general
s
This message was deleted.
j
Hi! looks like you're building a self-contained Spark application with Scala. Then you should add the pulsar client dependency to your
built.sbt
file. Here is an example:
val sparkVersion = "3.4.1"
val pulsarVersion = "3.1.0"
libraryDependencies ++= Seq(
"org.apache.spark" %% "spark-core" % sparkVersion,
"org.apache.spark" %% "spark-sql" % sparkVersion,
"org.apache.spark" %% "spark-streaming" % sparkVersion,
"org.apache.pulsar" % "pulsar-client" % pulsarVersion,
"org.apache.pulsar" %% "pulsar-spark" % pulsarVersion
)
Hope that helps
Unrelated issue: it looks like you have a typo in your topic name: two S at the end of
customers
The topic name should also include the prefix. For example:
<persistent://public/default/customers>
f
It worked, I passed pulsar package in spark session