I want to ingest data from an AVRO-encoded Pulsar ...
# getting-started
g
I want to ingest data from an AVRO-encoded Pulsar topic into a Pinot REALTIME table. Is that currently possible? If so, how can I do it?
n
@GerardJ You should be able to. You have to configure the stream decoder to use the
AvroMessageDecoder
. Example:
Copy code
"stream.pulsar.decoder.class.name": "org.apache.pinot.plugin.inputformat.avro.KafkaAvroMessageDecoder"
You can use the doc shown above to figure out the configurations for the decoder.
a
if you don't have a schema registry and all that setup, you can try
org.apache.pinot.plugin.inputformat.avro.SimpleAvroMessageDecoder
(but if you do, the other avro decoders will be better)