Skip to main content

validate_heartbeat_interval

risingwave_frontend::handler::create_source

Function validate_heartbeat_interval 

Source 
pub fn validate_heartbeat_interval(
    props: &BTreeMap<String, String>,
) -> Result<()>
Expand description

Requires an explicitly supplied heartbeat interval to be a positive signed 32-bit integer. Keep this policy in sync with Java’s SourceValidateHandler.validateHeartbeatInterval. Validates user-supplied options, not the final Debezium configuration. On CREATE, an omitted interval uses the connector default; on ALTER, omission leaves the existing interval unchanged. Unrelated connector heartbeat mechanisms are not checked here.