What would you like to happen?

Currently the connector publishes messages to pulsar in a synchronous way.

https://github.com/apache/beam/blob/master/sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/WriteToPulsarDoFn.java#L48

We need to make this publishing process async in order to improve the performance and throughput.

Issue Priority

Priority: 2

Issue Component

Component: io-java-pulsar