Hi, Mostly out of curiosity I'm writing a Kafka client, and I'm getting stuck at decoding fetch responses. Most of the time everything goes fine, but quite often I get frames back that seem to be wrong. I'm sure I've misunderstood something about the spec, so maybe someone can get me on the right track.
I get frames where the MessageSetSize is 2048, but it contains messages whose MessageSize is larger than this. The MessageSetSize is always 2048, which makes me suspicious. I've tried feeding these message sets to the Java client (into MemoryRecords.readableRecords), but when I iterate over it, it is empty. Further inspecting what it does with the bytes I see that it gets an EOFException and stops iterating, and I don't really understand what's going on. I'm doing these fetch requests against a cluster running 0.8.2.1. yours, Theo
