smbecker opened a new issue, #223: URL: https://github.com/apache/pulsar-dotpulsar/issues/223
### Description I have a batch process that when it kicks off, will fill a topic with around 100k messages in a very short period of time. I have a series of consumers that start pulling from that topic. If I use the default `MaxDegreeOfParallelism=1`, then everything finishes successfully as expected. I wanted to play around with how changes to `MaxDegreeOfParallelism` impact performance. My first test was using `MaxDegreeOfParallelism=10`. Unfortunately, after a few thousand messages, it just stopped consuming. I am still trying to work through where it is hung up. If I restart the process, it will pick back up and get through another few thousand before getting stuck again. Any idea where to start debugging this issue? I am using `MessagePrefetchCount=1` and `SubscriptionType=KeyShared` for what its worth. ### Reproduction Steps In my case, having a topic with tens of thousands of messages in backlog and trying to process it with `MaxDegreeOfParallelism=10`. ### Expected behavior It should process the messages as expected ### Actual behavior It stops processing messages after a few thousand or so ### Regression? _No response_ ### Known Workarounds Change `MaxDegreeOfParallelism=1` ### Configuration _No response_ ### Other information _No response_ -- 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-unsubscr...@pulsar.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
