/// validate the configuration and generate target server and config which can be used
validate the configuration and generate target server and config which can be used
validate the configuration and generate target server and config which can be used
pub fn validate(self) -> Result<(ReplicaLeaderConfig, ConsumeLogConfig), CliError> {
        // profile specific configurations (target server)
        let target_server = ReplicaLeaderConfig::new(self.sc, self.spu, self.kf, self.profile)?;
        let max_bytes = self.max_bytes.unwrap_or(MAX_BYTES);
        // consume log specific configurations
        let consume_log_cfg = ConsumeLogConfig {
            topic: self.topic,
            partition: self.partition,
            from_beginning: self.from_beginning,
            continuous: self.continuous,
            offset: -1,
            max_bytes: max_bytes,
            output: self.output.unwrap_or(ConsumeOutputType::default()),
            suppress_unknown: self.suppress_unknown,
        };
        // return server separately from config
        Ok((target_server, consume_log_cfg))
    }
pub fn validate ( self ) -> Result < ( ReplicaLeaderConfig , ConsumeLogConfig ) , CliError > { // profile specific configurations (target server) let target_server = ReplicaLeaderConfig :: new ( self . sc , self . spu , self . kf , self . profile ) ? ; let max_bytes = self . max_bytes . unwrap_or ( MAX_BYTES ) ; // consume log specific configurations let consume_log_cfg = ConsumeLogConfig { topic : self . topic , partition : self . partition , from_beginning : self . from_beginning , continuous : self . continuous , offset : - 1 , max_bytes : max_bytes , output : self . output . unwrap_or ( ConsumeOutputType :: default ( ) ) , suppress_unknown : self . suppress_unknown , } ; // return server separately from config Ok ( ( target_server , consume_log_cfg ) ) }
validate the configuration and generate target server and config which can be used
validate the configuration and generate target server and config which can be used
self