Re: Cannot consum from Kinesalite using FlinkKinesisConsumer

2021-12-04 Thread jonas eyob
Hey Mika, Were using kinesalite 1.11.5 Yeah, after bumping it to 3.3.3 the first issue which was related to not being able to list shards disappeared and instead I'm seeing the same issue you are mentioning "The timestampInMillis parameter cannot be greater than the currentTimestampInMillis" Fo

Re: Cannot consum from Kinesalite using FlinkKinesisConsumer

2021-12-03 Thread Mika Naylor
Hey Jonas, May I ask what version of Kinesalite you're targeting? With 3.3.3 and STREAM_INITIAL_POSITION = "LATEST", I received a "The timestampInMillis parameter cannot be greater than the currentTimestampInMillis" which may be a misconfiguration on my setup, but with STREAM_INITIAL_POSITION = "

Cannot consum from Kinesalite using FlinkKinesisConsumer

2021-12-02 Thread jonas eyob
Hi all, I have a really simple pipeline to consume events from a local kinesis (kinesalite) and print them out to stdout. But struggling to make sense of why it's failing almost immediately The pipeline code: /* Added this to verify it wasn't a problem with AWS CBOR which needs to be disabled */