sijie commented on issue #4199: documentation: unclear how to use Pulsar IO URL: https://github.com/apache/pulsar/issues/4199#issuecomment-495985476 > I found these --deserialization-classname and --custom-serde-inputs parameters respectfully You can write your own source and sink for doing that. My previous comment was that most of the (built-in) connector implementations are just about transferring bytes data in and out of Pulsar. so if you are using Pulsar's built-in connectors, you don't need to specify those settings. For example, if you connect data from Kafka to Pulsar, it just reads bytes from kafka and write bytes to Pulsar. Pulsar doesn't interpret the data. So it depends on whether you are using Pulsar's built-in connectors and how are those connectors implemented. If you are planning to write own connector with protobuf, then you can write your own SerDe or use Pulsar's protobuf schema. If you can share more details about what you are planning to do, I can have a better idea on how to help you.
---------------------------------------------------------------- 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] With regards, Apache Git Services
