I have a databricks notebook which is to read stream from Azure Event Hub.My code does the following:1.Configure path for Eventhubs2.Read Streamdf_read_stream = (spark.readStream
.format("eventhubs")
.options(**conf)...
Thanks for your help! I realized what is the root cause now!My configuration was:conf = {}
conf["EVENT_HUB_CONN_STR"] = sc._jvm.org.apache.spark.eventhubs.EventHubsUtils.encrypt("Endpoint=sb://***.servicebus.windows.net/;SharedAccessKeyName=xxxx;Shar...
Hi Hubert, Thanks for the reply. After defining and adding processingTime and checkpointLocation path, I still encounter error.Updated code looks like this:display(df_read_stream, processingTime = "5 seconds", checkpointLocation = checkpointPath)1st ...
