We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7a3775a commit 0fbfaf8Copy full SHA for 0fbfaf8
kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/AbstractPulsarClient.java
@@ -64,7 +64,7 @@ public static PulsarClientImpl createPulsarClient(final PulsarService pulsarServ
64
final Consumer<ClientConfigurationData> customConfig) {
65
// It's migrated from PulsarService#getClient()
66
final ClientConfigurationData conf = new ClientConfigurationData();
67
- conf.setServiceUrl(kafkaConfig.isTlsEnabled()
+ conf.setServiceUrl(kafkaConfig.isBrokerClientTlsEnabled()
68
? pulsarService.getBrokerServiceUrlTls()
69
: pulsarService.getBrokerServiceUrl());
70
conf.setTlsAllowInsecureConnection(kafkaConfig.isTlsAllowInsecureConnection());
0 commit comments