Hi folks, we are using KafkaJsonSchemaSerializer in the Kafka producer side, but we aren’t being able to decode the payload using Pinot ingestion. There are some unreadable chars at the beginning of the payload. I’ve tried different configurations without any success. BTW we are using Confluent Schema Registry.

Seems Pinot does not have the confluent schema registry json format support yet. Adding @Elon who contributed the

KafkaConfluentSchemaRegistryAvroMessageDecoder

Good timing, we are also talking about that:) To use it we need to upgrade to a more recent version of confluent schema registry libraries, then it can be used

@Elon But what if we don’t use Avro?

Yep, the pr would add support for json