Ask Your Question
0

Kinesis consumer failing when using InitialPosition "AT_TIMESTAMP"

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

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

1 Answer

Sort by ยป oldest newest most voted
1

answered 2019-03-20 14:10:27 -0500

jeff gravatar image

Sorry this was missed before. Please watch this issue for the fix, hopefully in an upcoming version in the near future.

edit flag offensive delete link more
Login/Signup to Answer

Question Tools

1 follower

Stats

Asked: 2018-10-02 17:32:12 -0500

Seen: 87 times

Last updated: Mar 20