Re: Large Size Error even when the message is small

Also the key serializer is org.apache.kafka.common.serialization.StringSerializer and value serializer = org.apache.kafka.common.serialization.ByteArraySerializer. On Wed, Mar 2, 2016 at 10:24 AM, Fang Wong wrote: > try (ByteArrayOutputStream bos = new

Re: Large Size Error even when the message is small

try (ByteArrayOutputStream bos = new ByteArrayOutputStream()) { try (DataOutputStream dos = new DataOutputStream(bos)) { // First element is the timestamp dos.writeLong(System.currentTimeMillis()); // Second element is the class name, this element is used for deserializing the

Re: Large Size Error even when the message is small

Can you show your code for sending? On Tue, 1 Mar 2016 at 21:59 Fang Wong wrote: > [2016-02-26 20:33:42,997] INFO Closing socket connection to /x due to > invalid request: Request of length 1937006964 is not valid, [2016-02-26 > 20:33:42,997] INFO Closing socket connection

Large Size Error even when the message is small

[2016-02-26 20:33:42,997] INFO Closing socket connection to /x due to invalid request: Request of length 1937006964 is not valid, [2016-02-26 20:33:42,997] INFO Closing socket connection to /10.224.146.58 due to invalid request: Request of length 1937006964 is not valid, it is larger than the