Apache Pulsar has provided a DataStream API based Connector in Apache Flink that can read and write Pulsar and develop batch converged applications. In this talk, Sheng Yufan will introduce the technical details behind Connector and how Pulsar’s various capabilities can be used and supported on Connector. We will demonstrate how to design and develop a consistent, high-throughput flow computing application based on Connector.

Speakers:

YuFan Sheng: StreamNative, Flink Development Engineer, Currently, I am working at StreamNative, responsible for the development of Flink-connector-Pulsar module under the main warehouse of Flink, as well as the development and maintenance of StreamNative Cloud related modules.