-
Notifications
You must be signed in to change notification settings - Fork 3.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Issue 8974: Peeking at compressed messages throws an exception (Readonly buffers not supported by Airlift) #8990
Issue 8974: Peeking at compressed messages throws an exception (Readonly buffers not supported by Airlift) #8990
Conversation
…nly buffers not supported by Airlift)
@merlimat @codelipenghui @rdhabalia PTAL |
That is ok, this is only used when peeking messages. For regular producer/consumer compression it's done on the direct memory instead, without copy. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We could also add a test to peek compressed messages, so we have the end-to-end validation.
@merlimat I wasn't able to reproduce the problem with and end-to-end test (using the existing end-to-end tests about compression). |
There are already tests that are spinning up real BK, just need to inherit from |
/pulsarbot run-failure-checks |
/pulsarbot run-failure-checks |
3 similar comments
/pulsarbot run-failure-checks |
/pulsarbot run-failure-checks |
/pulsarbot run-failure-checks |
…nly buffers not supported by Airlift) (#8990) Fixes #8974 ### Motivation In certain cases peeking messages on compresses topics return an error, see #8974 because Airlift does not support readonly ByteBuffers, because they do not give access to the underlying array) ### Modifications Copy the ByteByffer in case of unsupported buffer type ### Verifying this change This change adds new tests that reproduce the error and demonstrate that the problem is fixed. (cherry picked from commit cbc606b)
…nly buffers not supported by Airlift) (#8990) Fixes #8974 ### Motivation In certain cases peeking messages on compresses topics return an error, see #8974 because Airlift does not support readonly ByteBuffers, because they do not give access to the underlying array) ### Modifications Copy the ByteByffer in case of unsupported buffer type ### Verifying this change This change adds new tests that reproduce the error and demonstrate that the problem is fixed. (cherry picked from commit cbc606b)
Fixes #8974
Motivation
In certain cases peeking messages on compresses topics return an error, see #8974 because Airlift does not support readonly ByteBuffers, because they do not give access to the underlying array)
Modifications
Copy the ByteByffer in case of unsupported buffer type
Verifying this change
This change adds new tests that reproduce the error and demonstrate that the problem is fixed.