[FLINK-3239] Support for Kerberos enabled Kafka 0.9.0.0

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.2.0
• Assignee: Vijay Srinivasaraghavan
• Reporter: Niels Basjes
• Created: 15/Jan/16 12:11
• Updated: 20/Sep/16 23:28
• Resolved: 20/Sep/16 23:28

Description

In Kafka 0.9.0.0 support for Kerberos has been created ( KAFKA-1686 ).
Request: Allow Flink to forward/manage the Kerberos tickets for Kafka correctly so that we can use Kafka in a secured environment.
I expect the needed changes to be similar to FLINK-2977 which implements the same support for HBase.

Issue Links

• relates to: KAFKA-1696 Kafka should be able to generate Hadoop delegation tokens
• relates to: FLINK-3929 Support for Kerberos Authentication with Keytab Credential
• relates to: FLINK-3670 Kerberos: Improving long-running streaming jobs
• requires: FLINK-3058 Add Kafka consumer for new 0.9.0.0 Kafka API
• requires: FLINK-3929 Support for Kerberos Authentication with Keytab Credential