Method parse_kafka_broker

src/sql-parser/src/parser.rs:2765–2788

(&mut self)

    }

    fn parse_kafka_broker(&mut self) -> Result<WithOptionValue<Raw>, ParserError> {
        let _ = self.consume_token(&Token::Eq);
        let address = self.parse_literal_string()?;
        let tunnel = if self.parse_keyword(USING) {
            match self.expect_one_of_keywords(&[AWS, SSH])? {
                AWS => {
                    self.expect_keywords(&[PRIVATELINK])?;
                    KafkaBrokerTunnel::AwsPrivatelink(self.parse_aws_privatelink()?)
                }
                SSH => {
                    self.expect_keywords(&[TUNNEL])?;
                    KafkaBrokerTunnel::SshTunnel(self.parse_raw_name()?)
                }
                _ => unreachable!(),
            }
        } else {
            KafkaBrokerTunnel::Direct
        };

        Ok(WithOptionValue::ConnectionKafkaBroker(KafkaBroker {
            address,
            tunnel,
        }))
    }

    fn parse_kafka_broker_aws_privatelink_option(
        &mut self,