tree b4a6dc04ce74f47e6a620ea73931e2226adbb2fe
parent afde244da33c015ea0bac6f95dd3a1f72ec36c40
author Shivji Kumar Jha <shiv4289@gmail.com> 1554220921 +0530
committer Matteo Merli <mmerli@apache.org> 1554220921 -0700

issue#3939 : Allow client authentication from pulsar-flink package (#3949)

Problem:
========
pulsar-flink module (aka flink connector) internally uses pulsar-client. Though the pulsar client allows setting tokens in the client builder, the flink connector does not provide a way to pass authentication token to the pulsar client it uses internally.

Solution:
========
Accept authetication information as an input in pulsar-flink module. Pass this authentication information to pulsar-client.