| commit | a0a5598def99b80a347560724d358b77992052db | [log] [tgz] |
|---|---|---|
| author | Shivji Kumar Jha <shiv4289@gmail.com> | Sat May 18 17:57:04 2019 +0530 |
| committer | Sijie Guo <sijie@apache.org> | Sat May 18 05:27:04 2019 -0700 |
| tree | 77fbc8b53c3a454f14433813cf4ef05a64dc5da6 | |
| parent | 10a26e168e2158469a3e4bcc5abded1369d720d0 [diff] |
[Issue 4283][flink] construct auth when building pulsar source (#4284) Fixes #4283 ### Motivation pulsar flink connector now uses ClientConfigData to instantiate pulsar client. Pulsar client composes Authentication which can not be serialized. In an environment with Auth there is no way to set auth in pulsar client. ### Modifications Keep auth params away from persistence and serialization. Construct auth when building pulsar source