Support Questions
Find answers, ask questions, and share your expertise

Solace Integration with Spark Structured Streaming

Solved Go to solution

Solace Integration with Spark Structured Streaming

Explorer

Hi All,

 

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 

1 ACCEPTED SOLUTION

Accepted Solutions

Re: Solace Integration with Spark Structured Streaming

Explorer

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

1 REPLY 1

Re: Solace Integration with Spark Structured Streaming

Explorer

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