risingwave_connector::sink

Constant BOUNDED_CHANNEL_SIZE

source 
const BOUNDED_CHANNEL_SIZE: usize = 16;