[FLINK-13370] Allow Custom CuratorFramework

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Component/s: Runtime / Coordination
• Assignee: Unassigned
• Reporter: Matt Lloyd
• Created: 22/Jul/19 13:28
• Updated: 24/Jul/19 12:10
• Resolved: 24/Jul/19 11:22

Description

Due to how the CuratorFrameworkFactory is implemented in Flink, I am unable to use it with my existing Zookeeper clusters which rely on custom authentication.

To allow for this situation, I propose making the following changes to allow users to pass in custom factory methods (in a similar vein to FLINK-8660).

• Create FlinkCuratorFactory interface
• Move the current CuratorFramework factory method into a Factory class that implements the FlinkCuratorFactory interface
• Add new config zookeeper.curator.factory that defaults to the current implementation or takes the FQN of a user defined factory
• Replace the existing CuratorFramework factory method to uses the zookeeper.curator.factory config to call the appropriate factory.