pub fn channel_from_config_with_metrics( config: &StreamingConfig, metrics: ChannelMetrics, ) -> (Sender, Receiver)