xqianwang opened a new issue #10757:
URL: https://github.com/apache/pulsar/issues/10757


   **Describe the bug**
   Using java websocket client for publishing messages to pulsar. At the 
beginning it was good. But when producer send queue is full, pulsar websocket 
server ProducerHandler throws errors: ` Error occurred while producer handler 
was sending msg from /127.0.0.1:37254: 
org.apache.pulsar.client.api.PulsarClientException$ProducerQueueIsFullError: 
Producer send queue is full`. 
   On the java websocket client side, it still receive result ok ack from 
server: 
`{"result":"ok","messageId":"CPEKEINF","context":"1","errorCode":0,"schemaVersion":0}
 from server`
   **To Reproduce**
   Steps to reproduce the behavior:
   1. Launch pulsar standalone and java websocket client connecting pulsar 
websocket server producer endpoint.
   2. keep publishing messages until producer send queue is full. Pulsar 
websocket ProducerHandler throws errors.
   3. Websocket client still receive result ok message from server
   
   **Expected behavior**
   Websocket client sending message should be blocked. 
   
   **Screenshots**
   If applicable, add screenshots to help explain your problem.
   
   **Desktop (please complete the following information):**
    - OS: windows
   
   **Additional context**
   Add any other context about the problem here.
   


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

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to