Method parse_kafka_source_config_option

src/sql-parser/src/parser.rs:2805–2832

(
        &mut self,
    )

    }

    fn parse_kafka_source_config_option(
        &mut self,
    ) -> Result<KafkaSourceConfigOption<Raw>, ParserError> {
        let name = match self.expect_one_of_keywords(&[GROUP, START, TOPIC])? {
            GROUP => {
                self.expect_keywords(&[ID, PREFIX])?;
                KafkaSourceConfigOptionName::GroupIdPrefix
            }
            START => match self.expect_one_of_keywords(&[OFFSET, TIMESTAMP])? {
                OFFSET => KafkaSourceConfigOptionName::StartOffset,
                TIMESTAMP => KafkaSourceConfigOptionName::StartTimestamp,
                _ => unreachable!(),
            },
            TOPIC => {
                if self.parse_keyword(METADATA) {
                    self.expect_keywords(&[REFRESH, INTERVAL])?;
                    KafkaSourceConfigOptionName::TopicMetadataRefreshInterval
                } else {
                    KafkaSourceConfigOptionName::Topic
                }
            }
            _ => unreachable!(),
        };
        Ok(KafkaSourceConfigOption {
            name,
            value: self.parse_optional_option_value()?,
        })
    }

    fn parse_iceberg_sink_config_option(
        &mut self,