merlimat commented on pull request #10878: URL: https://github.com/apache/pulsar/pull/10878#issuecomment-858346821
> @merlimat the fact that the Integration test was broken is the real problem to me. > It means that inside a Sink you cannot use KeyValueSchema class API, and I bet you won't be able to use other classes. In the Sink you won't have access to the pulsar-client implementation, only the API. The implementation is loaded in a different class loader. > Do you suggest to bundle the pulsar-client with all of the dependencies in the NAR ? I'm not sure where I would have suggested that.. :) The pulsar-client is included in the worker-runtime. The NAR (or function jar will not have it (or they can add it on their own if they want, and it wouldn't conflict). The problem here is that the pulsar-client was being included in the java-instance.jar which is what gets added to the function/source/sink class loader. -- 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
