You are viewing a plain text version of this content. The canonical link for it is here.

Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2022/09/07 17:03:23 UTC

[GitHub] [beam] nlu90 opened a new issue, #22025: [Feature Request]: Make Pulsar IO connector publish messages asynchronously

nlu90 opened a new issue, #22025:
URL: https://github.com/apache/beam/issues/22025

   ### 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


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] github-actions[bot] closed issue #22025: [Feature Request]: Make Pulsar IO connector publish messages asynchronously

Posted by GitBox <gi...@apache.org>.

github-actions[bot] closed issue #22025: [Feature Request]: Make Pulsar IO connector publish messages asynchronously
URL: https://github.com/apache/beam/issues/22025


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] nlu90 commented on issue #22025: [Feature Request]: Make Pulsar IO connector publish messages asynchronously

Posted by GitBox <gi...@apache.org>.

nlu90 commented on issue #22025:
URL: https://github.com/apache/beam/issues/22025#issuecomment-1164735096

   https://github.com/apache/beam/pull/22026


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org