I am new to solace and spark structured streaming. I would like to write a solace consumer using spark structured streaming and with the below code
var df = spark.readStream.format("solacestream").load
I am getting java.lang.ClassNotFoundException: solacestream.DefaultSource
Any hint of the format of the solace jms and how to pass in the connection parameters as option to the spark will be helpful. Thanks
After initial read on Spark Structured Streaming , for custom receivers class named DefaultSource should be present in the package mentioned in the format of readStream.
View solution in original post