How can I manually set the

replication_key_value

? I am tapping an API where I must sort descending, so I want

replication_key_value

to be a timestamp of when I start a tap run. I set

self.replication_key_value

in the stream, but the state that is emitted is not affected by this