Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 2A4BE200B3C for ; Wed, 13 Jul 2016 19:08:22 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 28BF4160A6E; Wed, 13 Jul 2016 17:08:22 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 9F057160A6A for ; Wed, 13 Jul 2016 19:08:21 +0200 (CEST) Received: (qmail 36339 invoked by uid 500); 13 Jul 2016 17:08:20 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 36327 invoked by uid 99); 13 Jul 2016 17:08:20 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Jul 2016 17:08:20 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 8EF742C02A4 for ; Wed, 13 Jul 2016 17:08:20 +0000 (UTC) Date: Wed, 13 Jul 2016 17:08:20 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-4197) Allow Kinesis Endpoint to be Overridden via Config MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Wed, 13 Jul 2016 17:08:22 -0000 [ https://issues.apache.org/jira/browse/FLINK-4197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15375360#comment-15375360 ] ASF GitHub Bot commented on FLINK-4197: --------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2227 > 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 > Labels: easyfix > Fix For: 1.0.4 > > Original Estimate: 1h > Remaining Estimate: 1h > > 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 (v6.3.4#6332)