Hi, I'm looping in Gordon and Thomas, they might have some idea about how to resolve this.
Best, Aljoscha > On 3. Oct 2018, at 17:29, Vijay Balakrishnan <bvija...@gmail.com> wrote: > > I have been trying with all variations to no avail of java > -Dhttp.nonProxyHosts=.. -Dhttps.proxyHost=http://... -Dhttps.proxyPort=911 > -Dhttps.proxyUser= -Dhttps.proxyPassword=.. -Dhttp.proxyHost=http://.. > -Dhttp.proxyPort=911 -Dhttp.proxyUser=... -Dhttp.proxyPassword=... -jar .. > after looking at the code in com.amazonaws.ClientConfiguration > > On Tue, Oct 2, 2018 at 3:49 PM Vijay Balakrishnan <bvija...@gmail.com > <mailto:bvija...@gmail.com>> wrote: > HI, > How do I use FlinkKinesisConsumer using the Properties through a proxy ? > Getting a Connection issue through the proxy. > Works outside the proxy. > > Properties kinesisConsumerConfig = new Properties(); > kinesisConsumerConfig.setProperty(AWSConfigConstants.AWS_REGION, > region); > > if (local) { > > kinesisConsumerConfig.setProperty(AWSConfigConstants.AWS_ACCESS_KEY_ID, > accessKey); > > kinesisConsumerConfig.setProperty(AWSConfigConstants.AWS_SECRET_ACCESS_KEY, > secretKey); > } else { > > kinesisConsumerConfig.setProperty(AWSConfigConstants.AWS_CREDENTIALS_PROVIDER, > "AUTO"); > } > > //only for Consumer > > kinesisConsumerConfig.setProperty(ConsumerConfigConstants.SHARD_GETRECORDS_MAX, > "10000"); > > kinesisConsumerConfig.setProperty(ConsumerConfigConstants.SHARD_GETRECORDS_INTERVAL_MILLIS, > "2000"); > FlinkKinesisConsumer<Tuple2<InputMetadata, CameraWithCube>> > kinesisConsumer = new FlinkKinesisConsumer<>( > "kinesisTopicRead", new Tuple2KinesisSchema(), > kinesisConsumerConfig); > > > TIA
