risingwave_connector::source::kinesis

Function kinesis_reader_default_eof_retry_interval_ms

Source 
const fn kinesis_reader_default_eof_retry_interval_ms() -> u64