ksnijjer opened a new issue, #9990:
URL: https://github.com/apache/pinot/issues/9990
If user wants to use the Avro message decoder for e.g below config
"streamConfigs": {
"streamType": "kafka",
"stream.kafka.consumer.type": "lowlevel",
"stream.kafka.topic.name": "<topic>",
"stream.kafka.decoder.class.name":
"org.apache.pinot.plugin.inputformat.avro.SimpleAvroMessageDecoder",
"stream.kafka.consumer.factory.class.name":
"org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory",
"stream.kafka.broker.list": "<broker>",
"stream.kafka.consumer.prop.auto.offset.reset": "largest"
}
then it will throw an error: "the avro schema must be provided", however
there is no documentation on how to do that.
Relevant field is "stream.kafka.decoder.prop.schema", please document this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
