err: gzip: invalid header

[butnet]

kafka/broker.go

Line 1218 in 1ad0bf3

c.msgbuf, err = c.consume()

the same message can be receive by client in java.

[dgellow]

Hello @butnet,

Could you provide more context?

[butnet]

@dgellow :
it can't repet in my local environmental, it happen in prod environmental.
I just get the error message, no more.

[vma]

Hi,
I got the same issue after a module upgrade. I narrowed it down to the consumer's MaxFetchSize param. I had to set it explicitely to 0 to solve the issue as setting it to any number up to INT32_MAX didn't help.

As for the context, I am consuming big gziped json messages. Once unzipped, they can expand to 3 or 4MB but stay below 2MB when zipped.