[FLINK-8945] [kinesis] Allow customization of KinesisProxy

This closes apache#5698
lyft · Mar 16, 2018 · 1647b31 · 1647b31
1 parent f08e701
commit 1647b31
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...nesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java b/...nesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
@@ -120,7 +120,7 @@ public class KinesisProxy implements KinesisProxyInterface {
 	 *
 	 * @param configProps configuration properties containing AWS credential and AWS region info
 	 */
-	private KinesisProxy(Properties configProps) {
+	protected KinesisProxy(Properties configProps) {
 		checkNotNull(configProps);
 
 		this.kinesisClient = AWSUtil.createKinesisClient(configProps);