Pulsar adaptor for Apache Spark

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

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

    Gradle

    用法

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