You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/09/28 02:27:33 UTC

[GitHub] [pulsar] lordcheng10 opened a new issue #12216: When the producer is closing, it should wait for all pending write requests to persist

lordcheng10 opened a new issue #12216:
URL: https://github.com/apache/pulsar/issues/12216


   ## Motivation
   In the implementation of the producer's close method, the pending write request is not waited for persistence。
   For example, in the following example, after the producer is closed, the data is not successfully written to the server, and it seems that the data is lost:
   `
    try {
           PulsarClient client = PulsarClient.builder().serviceUrl("pulsar://127.0.0.1:6650").build();
           Producer<byte[]> producer = client.newProducer().topic("test1").create();
           producer.sendAsync("hello".getBytes());
           client.close();
       } catch (PulsarClientException e) {
           e.printStackTrace();
       }
       Thread.sleep(1000);
   `
   


-- 
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: commits-unsubscribe@pulsar.apache.org

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



[GitHub] [pulsar] lordcheng10 closed issue #12216: When the producer is closing, it should wait for all pending write requests to persist

Posted by GitBox <gi...@apache.org>.
lordcheng10 closed issue #12216:
URL: https://github.com/apache/pulsar/issues/12216


   


-- 
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: commits-unsubscribe@pulsar.apache.org

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



[GitHub] [pulsar] lordcheng10 commented on issue #12216: When the producer is closing, it should wait for all pending write requests to persist

Posted by GitBox <gi...@apache.org>.
lordcheng10 commented on issue #12216:
URL: https://github.com/apache/pulsar/issues/12216#issuecomment-928642850


   Corresponding PR:https://github.com/apache/pulsar/pull/12195


-- 
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: commits-unsubscribe@pulsar.apache.org

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



[GitHub] [pulsar] github-actions[bot] commented on issue #12216: When the producer is closing, it should wait for all pending write requests to persist

Posted by GitBox <gi...@apache.org>.
github-actions[bot] commented on issue #12216:
URL: https://github.com/apache/pulsar/issues/12216#issuecomment-1053791856


   The issue had no activity for 30 days, mark with Stale label.


-- 
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: commits-unsubscribe@pulsar.apache.org

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



[GitHub] [pulsar] lordcheng10 commented on issue #12216: When the producer is closing, it should wait for all pending write requests to persist

Posted by GitBox <gi...@apache.org>.
lordcheng10 commented on issue #12216:
URL: https://github.com/apache/pulsar/issues/12216#issuecomment-928642850


   Corresponding PR:https://github.com/apache/pulsar/pull/12195


-- 
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: commits-unsubscribe@pulsar.apache.org

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