Slackbot
06/05/2023, 3:52 PMsijieg
06/05/2023, 4:50 PMdataabase.history.pulsar.service.url
, it will use the the client_auth_plugin and client_auth_params from the connector to connect.Joel Sonoda
06/05/2023, 5:39 PMdatabase.history.pulsar.service.url
wasn't set (and the documentation lists it as a required
configuration).
// pass pulsar.client.builder if database.history.pulsar.service.url is not provided
if (StringUtils.isEmpty(pulsarUrl)) {
String pulsarClientBuilder = SerDeUtils.serialize(sourceContext.getPulsarClientBuilder());
config.put(PulsarDatabaseHistory.CLIENT_BUILDER.name(), pulsarClientBuilder);
}
I can see this block of code where this setting takes effect, but I didn't think to look there before your suggestion.sijieg
06/05/2023, 10:46 PMAnonymitaet
06/06/2023, 1:26 AMNeng
06/06/2023, 1:27 AMAnonymitaet
06/06/2023, 1:32 AMHuanli Meng
06/06/2023, 2:09 AMclient_auth_plugin
and client_auth_params
from the connector will be used to connect.โ as there is no descriptions about client_auth_plugin
and client_auth_params
in debezium connector configuration section?Anonymitaet
06/14/2023, 2:22 AM