flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Scott Kidder (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4197) Allow Kinesis Endpoint to be Overridden via Config
Date Tue, 12 Jul 2016 02:32:10 GMT
Scott Kidder created FLINK-4197:

             Summary: Allow Kinesis Endpoint to be Overridden via Config
                 Key: FLINK-4197
                 URL: https://issues.apache.org/jira/browse/FLINK-4197
             Project: Flink
          Issue Type: Improvement
          Components: Kinesis Connector
    Affects Versions: 1.0.3
            Reporter: Scott Kidder
            Priority: Minor
             Fix For: 1.0.4

I perform local testing of my application stack with Flink configured as a consumer on a Kinesis
stream provided by Kinesalite, an implementation of Kinesis built on LevelDB. This requires
me to override the AWS endpoint to refer to my local Kinesalite server rather than reference
the real AWS endpoint. I'd like to add a configuration property to the Kinesis streaming connector
that allows the AWS endpoint to be specified explicitly.

This should be a fairly small change and provide a lot of flexibility to people looking to
integrate Flink with Kinesis in a non-production setup.

This message was sent by Atlassian JIRA

View raw message