devinbost edited a comment on issue #6054: URL: https://github.com/apache/pulsar/issues/6054#issuecomment-827768089
I was able to reproduce this issue on a cluster with a single broker and a partitioned topic (with 4 partitions) sending messages to a single filter function that was also running on that broker. I was also able to reproduce it using a non-partitioned topic after allowing backlog to accumulate (by stopping the function) and then resuming the function after several thousand messages accumulated on the backlog. Traffic must be sufficiently high velocity to reproduce the issue. We bulk-loaded data from NiFi to reproduce. -- 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]
