>> Any help on this would be highly appreciated.
>>
>>
>>
>> Thanks for all the help so far.
>>
>>
>>
>> Regards,
>>
>> Phani Geeth
>>
>> Sent from Mail <https://go.microsoft.com/fwlink/?LinkId=550986> for
>>
There could be any number of reasons for that, it's hard to say without
knowing how you're running the pipeline. There's a pretty good chance the
message is indeed being printed, but not on a console you can see easily.
Personally for this kind of testing I tend to use metrics to get quick
feedback
Thanks Byron for the quick response it worked by creating Serializable
Function and generating client inside it.
One more help is how to display pulsar message while adding DoFn in
pipeline it's not printing messages, able to see pipeline is recieving
messages but not able to display.
Class Messa
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 f
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 linkhttps://stackoverflow.com/questions/73937922/not-able-to-connect-to-pulsari
