Here is the sample script to invoke the connector
val struct_stream = spark.readStream.format("solace")
.option("host", "")
.option("vpn", "")
.option("username", "")
.option("password", "")
.option("queue", "")
.option("connectRetries", 3)
.option("reconnectRetries", 3)
.option("batchSize", 10000)
.option("partitions", 1)
.load()