commit 394ae522738169b163878ee6fc2d5b9f7d0349eb
author Shivji Kumar Jha <shiv4289@gmail.com> Tue Apr 02 21:32:01 2019 +0530
committer Matteo Merli <mmerli@apache.org> Tue Apr 02 09:02:01 2019 -0700
tree b4a6dc04ce74f47e6a620ea73931e2226adbb2fe
parent afde244da33c015ea0bac6f95dd3a1f72ec36c40

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.