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

[Lian Jiang]

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