wmccarley opened a new issue #5433: Implementing a Sink to a non thread-safe destination URL: https://github.com/apache/pulsar/issues/5433 I am implementing a Sink to a proprietary socket-based system. The API provided by the destination system does not supply thread-safe classes and write methods. Is the write method of a class implementing the Pulsar Sink interface expected to be thread safe? If yes, can someone explain the lifecycle of a Sink within a given JVM? - When exactly is open/close called? - Can multiple instances of the same Sink class be instantiated in one JVM? - What happens when I trigger a sink "update" command. The developer of the destination system suggested just use a ThreadLocal instance of the socket thingy. That _might be possible_ contingent upon the answers to the questions above but I don't like it. I am worried about leaking the socket thingys if I stop/start sinks etc.
---------------------------------------------------------------- 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
