eolivelli commented on a change in pull request #10267:
URL: https://github.com/apache/pulsar/pull/10267#discussion_r618124529
##########
File path: site2/docs/io-develop.md
##########
@@ -123,6 +163,57 @@ Developing a sink connector **is similar to** developing a
source connector, tha
You also need to ack records (if messages are sent successfully) or fail
records (if messages fail to send).
+## Handling Schema information
+
+Pulsar IO handles automatically the Schema and provides a strongly typed API
based on Java generics.
+If you know the Schema type that you are consuming from you can declare the
Java class relative to that type in your Sink declaration.
+
+```
+public class MySink implements Sink<String> {
+ public void write(Record<String> record) {}
+}
+```
+If you want to implement a Sink that works with any schema then you go with
the special GenericObject interface.
Review comment:
done
--
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]
