Hello;
I am using the golang Consumer and ran into some errors when there was
a large backlog (greater than max message size) of messages on broker
and had a question about the format.
In the case above, the behavior i was seeing was the total packet
bytes size == max message (containing many mes
Aaron,
The consumer has to use a fetch size larger than the largest single message
(+ overhead, about 10 bytes). Otherwise, the consumer won't be able to
decode a single message from a fetched chunk and will get stuck.
Thanks,
Jun
On Tue, Jan 3, 2012 at 2:08 PM, Aaron Raddon wrote:
> Hello;
>
