Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
03-04-2025 10:20 PM
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()
