Re: Can't get the FlinkKinesisProducer to work against Kinesalite for tests

2018-10-01 Thread Fabian Hueske
Hi Bruno, Thanks for sharing your approach! Best, Fabian Am Do., 27. Sep. 2018 um 18:11 Uhr schrieb Bruno Aranda : > Hi again, > > We managed at the end to get data into Kinesalite using the > FlinkKinesisProducer, but to do so, we had to use different configuration, > such as ignoring the 'aws

Re: Can't get the FlinkKinesisProducer to work against Kinesalite for tests

2018-09-27 Thread Bruno Aranda
Hi again, We managed at the end to get data into Kinesalite using the FlinkKinesisProducer, but to do so, we had to use different configuration, such as ignoring the 'aws.endpoint' setting and going for the ones that the Kinesis configuration will expect. So, to our FlinkKinesisProducer we pass co

Can't get the FlinkKinesisProducer to work against Kinesalite for tests

2018-09-26 Thread Bruno Aranda
Hi, We have started to use Kinesis with Flink and we need to be able to test when a Flink jobs writes to Kinesis. For that, we use a docker image with Kinesalite. To configure the producer, we do like it is explained in the docs [1]. However, if we use this code, the job submission is going to f