Hi Michael, It's not the same here.
If you use AuthenticationTLS, which means you enable TLS authentication and
transport.
```
PulsarClient client = PulsarClient.builder()
.serviceUrl("pulsar://my-host:6651")
.tlsTrustCertsFilePath("/path/to/cacert.pem")
.tlsKeyFilePath("/
+1 (non-binding)
Thanks,
Yunze
[
https://issues.apache.org/jira/browse/PULSAR-20?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Kania updated PULSAR-20:
--
Description:
I am getting the following exception while using Flink with Pulsar where I
believe the top
[
https://issues.apache.org/jira/browse/PULSAR-20?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537128#comment-17537128
]
Penghui Li commented on PULSAR-20:
--
[~longtimer] Thanks for your feedback.
We will impro
[
https://issues.apache.org/jira/browse/PULSAR-20?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537134#comment-17537134
]
Penghui Li commented on PULSAR-20:
--
[~longtimer] I have pushed out a PR
[https://github.