lizhimins commented on issue #6205: URL: https://github.com/apache/rocketmq/issues/6205#issuecomment-1451766305
> > Does anyone want to try? > > I want to try. but I don't know if I understood this correctly, just change the value of input parameter to async for pullKernelImpl method？ This is actually a thread model problem. The implementation of synchronization is relatively simple, Each thread can use a loop to continuously obtain messages from the broker. For asynchronous pull, execute the next request in the callback of the last long poll. Please refer to the push consumer. (click the avatar to get contact wx -- 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]
