or maybe the right way to implement this would be to yield an "empty" record when there is no events for the range so the

replication_key

thing works