Spark Connector to read and write with Pulsar
Pure batching for Scala
Elastic data processing with Apache Pulsar and Apache Flink