Apache Pinot

Getting `failed to index value with DICTIONARY` when ingesting avro-formatted data from Kafka. Any ideas? Using KafkaConfluentSchemaRegistryAvroMessageDecoder.

there should be additional information about the exception in the log

this generally means the values were null and decoder was not able to decode the payload

Screenshot 2022-08-12 at 11.39.06 AM.png

This is a contiguous log from reading 6 records from kafka. There’s no other log between 2 consecutive consumptions

This worked when I replaced implicit class to avro convertion with an manually constructed schema.