-
Notifications
You must be signed in to change notification settings - Fork 3.2k
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
Failed to decompress gzip #54
Comments
Us there a minimum size required for compression to work? |
Do you know what produced this message? Scala Kafka producer? rdkafka producer? I dont think gzip has any limits on the size of the uncompressed data. |
My app using rdkafka. When I do no compression it works fine, when I do gzip it doesnot complain on the publisher side (but does in the consumer), and when I do snappy I get a message timed out error. |
Reproduced this using rdkafka example on both sides |
Perfect! Can you provide the exact command lines for both producer and consumer as well as your sample message(s)? |
Note I have not updated from master since Dec 28 in case it matters. My message was on stdin and was simple like 'hi'. ./rdkafka_example -C -b kafkadevcluster1-1.masked.com:5757, ./rdkafka_example -P -b kafkadevcluster1-1.masked.com:5757, With either –z gzip, -z snappy or (nothing) On Tuesday, January 7, 2014, Magnus Edenhill wrote:
|
Gzip decompression should now be working. |
Ok cool. The snappy seemed to be a publisher side problem since it On Tuesday, January 7, 2014, Magnus Edenhill wrote:
|
Magnus- let me know if you think the snappy fix will be a straightforward one or will require some time- so that I can decide whether to update the code base now to get the gzip fix or to wait to get both. Thanks in advance. |
I will hopefully have time to look at the snappy issue tonight (utc)
|
Updated, gzip now works. On Wednesday, January 8, 2014, Magnus Edenhill wrote:
|
Creating a separate issue for snappy. |
I'm setting gzip in my publisher and am receiving this in rdkafka_example:
1389132516.572 RDKAFKA-7-GZIP: rdkafka#consumer-0: d145931-002.masked.com:5757/0: Failed to decompress Gzip message at offset 3145 of 216 bytes: ignoring message
I get this whether -z gzip is set or not. Any idea?
The text was updated successfully, but these errors were encountered: