Deserialization of MetadataResponse and ProduceResponse were constantly failing for me, with "System.IO.EndOfStreamException: Attempted to read past the end of the stream.", so I was suspicious of trying to read more data then needed.
This fix is completely experimental, I haven't checked the kafka protocol reference whether this is correct, or not. It just works for me.
Deserialization of MetadataResponse and ProduceResponse were constantly failing for me, with "System.IO.EndOfStreamException: Attempted to read past the end of the stream.", so I was suspicious of trying to read more data then needed.
This fix is completely experimental, I haven't checked the kafka protocol reference whether this is correct, or not. It just works for me.