[GitHub] flink pull request #5411: [FLINK-8556] [Kinesis Connector] Add proxy feature...

[pduveau <gi...@git.apache.org>]

GitHub user pduveau opened a pull request:

    https://github.com/apache/flink/pull/5411

    [FLINK-8556] [Kinesis Connector] Add proxy feature to the connector

    ## The purpose of the change
    
    The connector can not be configured to use a proxy to access Kinesis endpoint.
    This feature is required if running on EC2 instances which can access internet only through a proxy.
    VPC Kinesis endpoints are currently available in few AWS' regions.
    
    ## Change log
    
    The configuration is extended with new parameters for all supported proxy of the AWS Client Configuration.
    Can be configured as Anonymous or with any combination of authentication's methods BASIC, DIGEST, SPNEGO, 
    KERBEROS and NTML.
    
    ## Verifying this change
    
    No test added to check those optionnal paramaters. The check is done at runtime by validating the configuration.
    
    ## Does this pull request potentially affect one of the following parts:
    
      - Dependencies (does it add or upgrade a dependency): no
      - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: no
      - The serializers: no
      - The runtime per-record code paths (performance sensitive): no
      - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: no
      - The S3 file system connector: no
    
    ## Documentation
    
      - Does this pull request introduce a new feature? yes
      - If yes, how is the feature documented? JavaDocs

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/pduveau/flink Kinesis_add_proxy_parameters

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/5411.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #5411
    
----
commit 89dcc7b34f0eb1ba3d412919b0ece89bc822f056
Author: Philippe Duveau <ph...@...>
Date:   2018-02-04T11:25:15Z

    Adds proxy feature to the connector to access Kinesis endpoint.

----


---

[GitHub] flink issue #5411: [FLINK-8556] [Kinesis Connector] Add proxy feature to the...

[pduveau <gi...@git.apache.org>]

Github user pduveau commented on the issue:

    https://github.com/apache/flink/pull/5411
  
    Hi @tzulitai, Were you able to get time to check this PR ? We have interest in an official version including this.


---

[GitHub] flink issue #5411: [FLINK-8556] [Kinesis Connector] Add proxy feature to the...

[tzulitai <gi...@git.apache.org>]

Github user tzulitai commented on the issue:

    https://github.com/apache/flink/pull/5411
  
    Thanks for the contribution @pduveau.
    I'll try to take a look at this soon.


---

[GitHub] flink issue #5411: [FLINK-8556] [Kinesis Connector] Add proxy feature to the...

[tzulitai <gi...@git.apache.org>]

Github user tzulitai commented on the issue:

    https://github.com/apache/flink/pull/5411
  
    Hi @pduveau, sorry for the delay here.
    I've previously been busy with recent releases, and am currently traveling for Flink Forward.
    
    This PR is still on my backlog, will try to get back to it as soon as possible.


---