在Databricks Jar任务中查询com.microsoft.azure:azure-eventhubs-spark_2.12:2.3.22主类

这个com.microsoft.azure:azure-eventhubs-spark_2.12:2.3.22库是Spark与Azure Event Hubs的连接器，本身没有可直接执行的主类——它是作为依赖库供Spark应用调用的，不是可以独立运行的Jar包。

正确的使用方式分两种情况：

• 若要在Databricks中用它读取/写入Event Hubs：不需要通过Jar任务指定主类，直接在集群的「Libraries」页面添加该Maven库作为集群依赖。之后在Notebook或作业代码里直接调用连接器API即可，比如：

  import org.apache.spark.eventhubs._
  val eventHubsConf = EventHubsConf("<connection-string>")
  val df = spark.readStream.format("eventhubs").options(eventHubsConf.toMap).load()
  

• 若你是要运行自己的Jar应用并依赖这个库：主类应该是你自己编写的应用程序的主类，这个Azure库只是你的代码的依赖项。你可以用Maven Shade插件把依赖打包进自己的Jar，或者在Databricks作业中同时配置你的Jar和这个Maven依赖库。

内容的提问来源于stack exchange，提问作者Beesure