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
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
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