Pulsar adaptor for Apache Spark

    应用程序可以通过 Spark Streaming receiver 接收 Resilient Distributed Dataset (RDD) 格式的数据，并可以通过多种方式对其进行处理。

    Maven

    如果你使用maven,添加以下内容到你的 pom.xml 中:

    Gradle

    用法

    把一个 SparkStreamingPulsarReceiver 实例，传入 的receiverStream方法中作为的参数:

    请注意，如果需要，可以使用其他 Pulsar 认证类。 例如，为了在认证过程中使用令牌，可以为 构造函数设置以下参数。