Announcing: The Pulsar PMC Published The 2020 Apache Pulsar User Survey Report!

Overview
Get started
Install and upgrade
Configure
Secure
Manage and monitor
Connect
Process
Overview
Pulsar Flink Connector
Overview
Link
Read data from Pulsar (source)
Write data to Pulsar (sink)
Configure
Secure
Use Pulsar catalog
Tutorial
Pulsar Spark Connector
Pulsar Functions
Release notes

Secure Pulsar Flink connector

If you want to set the encryption and authentication settings for Pulsar Flink connector, follow the steps below.

Encryption and authentication settings

When your Pulsar instance is configured with TLS encryption or any authentication enabled, you can easily adapt your read or write program by choosing the constructors which ask for ClientConfigurationData as one of the arguments.

For ClientConfigurationData, set authentication or TLS related fields as below.

ClientConfigurationData clientConf = new ClientConfigurationData();
clientConf.setServiceUrl("pulsar://localhost:6650"); // this field is mandatory.
clientConf.setAuthPluginClassName();
clientConf.setAuthParams();
clientConf.setUseTls();
clientConf.setTlsTrustCertsFilePath();
clientConf.setTlsAllowInsecureConnection();
clientConf.setTlsHostnameVerificationEnable();