sijie commented on pull request #9481: URL: https://github.com/apache/pulsar/pull/9481#issuecomment-780015838
@codelipenghui: Most of the understandings are correct. There is one mistake. We don't use `AUTO_CONSUME` for serializing the messages. We just use `AUTO_CONSUME` to tell PulsarSink that it doesn't need to pre-create a producer. The messages produced to the sink are all `GenericRecord`s. They all carry the schema information themselves. Then we leverage PIP-45 to write the messages based on the schema information they carry. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
