codelipenghui commented on PR #17154: URL: https://github.com/apache/pulsar/pull/17154#issuecomment-1219286097
> I'm just wondering if we have another easy way to make CompletableFuture execute sequentially and don't require many states. In this way, we also need to maintain a shared Future there. And if we don't want to create a Future for each message, we also need to check the Future state to decide to call `thenCompose()` or use it directly. And we'd better avoid the subsequent read operations during fetching the schema. If a broker has 10k topics run into this state, too many messages will be pending here which will use up the memory. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
