anvinjain edited a comment on issue #11044: URL: https://github.com/apache/pulsar/issues/11044#issuecomment-866709634
Continuing on the exploration, maybe this is as simple as changing https://github.com/apache/pulsar/blob/a070c3363d007198f5dee4d3d70d075ba6a1c8df/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java#L343 from serviceConfig.getDispatcherMaxReadSizeBytes() to Math.min(serviceConfig.getDispatcherMaxReadSizeBytes(), dispatch-byte-rate-limit) -- 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]
