Function sql::plan::statement::ddl::get_kafka_sink_consistency_config

fn get_kafka_sink_consistency_config(
    topic_prefix: &str, 
    sink_format: &KafkaSinkFormat, 
    config_options: &BTreeMap<String, String>, 
    reuse_topic: bool, 
    consistency: Option<KafkaConsistency<Raw>>, 
    consistency_topic: Option<String>
) -> Result<Option<(String, KafkaSinkFormat)>, Error>

Determines the consistency configuration (topic and format) that should be used for a Kafka sink based on the given configuration items.

This is slightly complicated because of a desire to maintain backwards compatibility with previous ways of specifying consistency configuration. KafkaConsistency is the new way of doing things, we support specifying just a topic name (via consistency_topic) for backwards compatibility.