search

datastax / starlight-for-kafka

DataStax - Starlight for Kafka
Apache License 2.0
17 stars 12 forks source link

Use brokerClientTlsEnabled to configure pulsar client #87

Closed michaeljmarshall closed 1 year ago

michaeljmarshall commented 1 year ago

The createPulsarClient method is meant to model the PulsarServer method named getClient. However, it uses a different config to determine when to enable TLS. This leads to divergent behavior within the broker. Here is the pulsar code:

https://github.com/apache/pulsar/blob/092819b5c4a68dbc39d9a650d5370af9455e805d/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java#L1554-L1555