[jira] [Created] (FLINK-29433) Support Auth through the builder pattern in Pulsar connector

[Yufan Sheng (Jira)]

Yufan Sheng created FLINK-29433:
-----------------------------------

             Summary: Support Auth through the builder pattern in Pulsar 
connector
                 Key: FLINK-29433
                 URL: https://issues.apache.org/jira/browse/FLINK-29433
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Pulsar
    Affects Versions: 1.16.0
            Reporter: Yufan Sheng


Currently in order to use auth with the Flink Connector you needs to do so 
through the {{setConfig}} method.
It would be nice if similar to the client API we can add methods inside the 
builder pattern.
Example:

{code:java}
builder.authentication(new AuthenticationToken(""))
{code}

We can do something similar for the connector instead of having to do:

{code:java}
PulsarSource.builder()
    .setConfig(PulsarOptions.PULSAR_AUTH_PLUGIN_CLASS_NAME, 
"org.apache.pulsar.client.impl.auth.oauth2.AuthenticationOAuth2")
    .setConfig(PulsarOptions.PULSAR_AUTH_PARAMS, "{"privateKey":"..."})
{code}




--
This message was sent by Atlassian Jira
(v8.20.10#820010)