Hi all,
I'm trying to resolve another exception... currently my code looks like:
@XmlElement(name = "TriggerDate")
@XmlSchemaType(name = "date")
protected XMLGregorianCalendar triggerDate;
@XmlElement(name = "TriggerTime")
@XmlSchemaType(name = "time")
protected XMLGregorianCalendar triggerTime;
public void sendMessage(Msg msg) throws IOException {
log.debug("Entering test message send...");
ReflectData reflectData = ReflectData.AllowNull.get();
Schema schema = reflectData.getSchema(Msg.class);
DatumWriter<Msg> writer = new ReflectDatumWriter<Msg>(schema);
ByteArrayOutputStream os = new ByteArrayOutputStream();
Encoder encoder = EncoderFactory.get().binaryEncoder(os, null);
writer.write(msg, encoder);
encoder.flush();
os.close();
KeyedMessage<String, byte[]> data = new KeyedMessage<String,
byte[]>(TOPIC_NAME, os.toByteArray());
producer.send(data);
}
and I'm getting the following exception:
org.apache.avro.UnresolvedUnionException: Not in union
["null",{"type":"record","name":"XMLGregorianCalendar","namespace":"javax.xml.datatype","fields":[]}]:
2014-10-22
Any ideas?
Nick