How to define byte[] and LocalDateTime in avro schema?

[Ratha v <vi...@gmail.com>]

Hi all;
Im new to Avro schema. I try to publish/consumer my java objects using
kafka.

I have java bean classes, which contains fields with LocalDateTime and
byte[] . How can I define both in avro schema primitive types?What is the
best primitive type i can use for LocalDateTime?

private LocalDateTime timestamp;
private byte[] content;

I defined something like this; but getting



* {            "name": "content", "type": "bytes"    },*

Class cast exception[1]

[1]
Caused by: java.lang.ClassCastException: [B cannot be cast to
java.nio.ByteBuffer at
org.apache.avro.generic.GenericDatumWriter.writeBytes(GenericDatumWriter.java:219)
at
org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:77)
at
org.apache.avro.generic.GenericDatumWriter.writeField(GenericDatumWriter.java:114)
at
org.apache.avro.generic.GenericDatumWriter.writeRecord(GenericDatumWriter.java:104)
at
org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:66)
at
org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:58)


--
-Ratha
http://vvratha.blogspot.com/