sijie commented on issue #5433: Implementing a Sink to a non thread-safe destination URL: https://github.com/apache/pulsar/issues/5433#issuecomment-546715842 > Is the write method of a class implementing the Pulsar Sink interface expected to be thread safe? yes. > When exactly is open/close called? open is called once when an instance of sink connector is initialized. close is called when an instance of sink connector is closed. the instance is closed when the instance is moving from one function worker to another function worker, or a function worker running the instance is shutting down. > Can multiple instances of the same Sink class be instantiated in one JVM? That's possible. If you configure the parallelism to be more than the number of function workers. Hope this provides the information you need.
---------------------------------------------------------------- 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: us...@infra.apache.org With regards, Apache Git Services
