Re: FlinkKinesisConsumer throws "Unknown datum type org.joda.time.DateTime"

[Chesnay Schepler]

What you could try is bumping the avro dependency to 1.9.2 . I don't 
whether this will /just work/, but it's worth a shot.

On 20/02/2020 16:25, Lian Jiang wrote:
Thanks. I see from mvnrepository that even Flink-Avro 1.10 (the latest) uses 
avro 1.8.2. Does this mean I have to use GenericData instead of avro POJOs if I 
use FlinkKinesisConsumer?
Sent from my iPhone

On Feb 20, 2020, at 4:34 AM, Chesnay Schepler <ches...@apache.org> wrote: