You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently you can customise STATE_MSG_FREQUENCY per stream class to control after how many records a state message is emitted. It would be good to be able to override this behaviour in a more nuanced manner, such as to emit state at regular date-time intervals based on the previous state replication key value (timestamp).
Feature scope
Taps (catalog, state, tests, etc.)
Description
Currently you can customise
STATE_MSG_FREQUENCY
per stream class to control after how many records a state message is emitted. It would be good to be able to override this behaviour in a more nuanced manner, such as to emit state at regular date-time intervals based on the previous state replication key value (timestamp).A
should_emit_state
method was proposed in Slack.The text was updated successfully, but these errors were encountered: