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/04/29 00:11:20 UTC

[GitHub] [pulsar] dlg99 commented on pull request #10420: [Kinesis]Fix kinesis sink can not retry to send messages

dlg99 commented on pull request #10420:
URL: https://github.com/apache/pulsar/pull/10420#issuecomment-828858706


   If I understood this approach correctly and to my best understanding of how the sink works, it will end up accumulating data in memory until the connection with kinesis is restored. If that takes too long, the PulsarSource will keep producing the data for the sink and eventually this will OOM. it needs a way (through the context?) to tell PulsarSource to pause. 


-- 
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:
users@infra.apache.org