jerrypeng opened a new pull request #3237: fix bug involving consumer producer 
deadlock in functions
URL: https://github.com/apache/pulsar/pull/3237
 
 
   ### Motivation
   
   Fixed bug involving potential deadlock between consuming and producing in 
functions. In functions, if a consumer is blocked from consuming due to unacked 
number of messages and the producer is unable to produce messages successfully. 
Those messages will be timed out and never ack, but those messages will never 
be redelivered to the consumer because i was already blocked.
   
   Thus we should set the send timeout on the producer to be infinity to keep 
on try to send the message

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to