ivankelly opened a new pull request #1043: RawReader allows futures to be cancelled URL: https://github.com/apache/incubator-pulsar/pull/1043 RawReader#readNextAsync returns a Future<RawMessage> to the user, which includes a retained ByteBuf. If the user is no longer interested in the result of the read call, it should be able to cancel to ensure that the ByteBuf is released. If there are multiple read requests outstanding, and one of them is cancelled, all read requests that were made after the cancelled request will also be cancelled.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services