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

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

Gradle

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