Our enrichers didn’t process some data due to a silly mistake on my end. Fortunately, it is still in the kinesis streams. It seems enrichers start points are set two ways:
- The config.hocon lets you specify a starting position (LATEST, etc)
- Dynamodb stores positions (I believe)
When killing and restarting the enrichment process, which of the above takes precedence? Do I need to delete the dynamodb entry before in order for the config entry to work?
Bonus question: If I were to do
initialPosition = AT_TIMESTAMP in the config where is it I specify the beginning timestamp in the config?