Hello, does pinot have support for ingesting avro kafka messages? Is it in the roadmap?
b
Bruce Ritchie
07/16/2021, 1:41 PM
There seems to be two Kafka Avro message decoders in the codebase that I think you can use "org.apache.pinot.plugin.inputformat.avro.KafkaAvroMessageDecoder"
and "org.apache.pinot.plugin.inputformat.avro.confluent.KafkaConfluentSchemaRegistryAvroMessageDecoder"