Kinesis consumer failing when using InitialPosition "AT_TIMESTAMP"

asked 2018-10-02 17:32:12 -0600

leo.wajnsztok gravatar image

I have a pipeline with a Kinesis consumer and I need to use the AT_TIMESTAMP option. After setting the InitialPosition option to AT_TIMESTAMP, setting the Initial timestamp option to 1538517600000 and starting the pipeline, it fails with the following error:

Pipeline Status: RUNNING_ERROR: java.lang.IllegalArgumentException: Invalid InitialPosition: AT_TIMESTAMP

Am I missing something or is it really not working properly?

If so, are there any plans to fix this feature or workaround I could try?

Thanks in advance!

edit retag flag offensive close merge delete