Hi Phani, I believe what you want to do here is construct the PulsarClient object within an implementation of SerializableFunction so that it can be executed remotely rather than constructing the client in your main function. That will mean ensuring that you have access to your certificate files from those remote resources as well.
Best, B On Thu, Oct 6, 2022 at 3:19 AM Phani Geeth <bvpgeeth0...@gmail.com> wrote: > Hi Team, > > > > I am using native PulsarIO to connect existing pulsar server with ssl > certification. But while adding withPulsarClient in pipeline I am getting > cast error. > > > > More details and code is posted in below stackoverflow link > > > https://stackoverflow.com/questions/73937922/not-able-to-connect-to-pulsario-using-apache-beam-java-sdk > > > > > > > > Regards, > > > > Phani Geeth > > > > > > Sent from Mail <https://go.microsoft.com/fwlink/?LinkId=550986> for > Windows > > >
