Skip to content
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

Misdetection of xerial snappy on RedPanda #2414

Open
vmarkovtsev opened this issue Nov 17, 2023 · 0 comments
Open

Misdetection of xerial snappy on RedPanda #2414

vmarkovtsev opened this issue Nov 17, 2023 · 0 comments

Comments

@vmarkovtsev
Copy link

We consume messages from a Kafka topic from RedPanda that are compressed with Snappy. Apparently, RedPanda is doing something not completely standard or with a newer format version, since kafka.codec._detect_xerial_stream fails to detect xerial, returns False, and the snappy_decode crashes with snappy.UncompressError: Error while decompressing: invalid input. Here are the first few bytes of a sample payload:

\x82SNAPPY\x00\x01\x00\x00\x00\x01\x00\x00\x00\x00\x00\xc3\x9b\x80\x80\x08\xf0\xaa\x98\x05\x00\x00

confluence-kafka works with RedPanda without a problem.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants