> > deserialized and check debug the AvroRowDeserializationSchema with it.
> >
> > Best,
> >
> > Dawid
> >
> > On 06/06/2020 16:27, Ramana Uppala wrote:
> > > We are using AvroRowDeserializationSchema with Kafka Table source to
> > deserialize
you correctly some records can be
>>> deserialized. If they were produced with the schema registry type of
>>> serialization all would fail.
>>>
>>> What I can recommend is to try to log/identify a record that cannot be
>>> deserialized and check debug the Avro
; On 06/06/2020 16:27, Ramana Uppala wrote:
> > We are using AvroRowDeserializationSchema with Kafka Table source to
> deserialize the messages. Application failed with "Failed to deserialize
> Avro record." for different messages it seems.
> >
> > Caused by:
ssages. Application failed with "Failed to deserialize Avro
> record." for different messages it seems.
>
> Caused by: org.apache.avro.AvroRuntimeException: Malformed data. Length is
> negative: -26
>
> Caused by: java.lang.A
We are using AvroRowDeserializationSchema with Kafka Table source to
deserialize the messages. Application failed with "Failed to deserialize Avro
record." for different messages it seems.
Caused by: org.apache.avro.AvroRuntimeException: Malformed data. Length is
negative: -
