Function sql::plan::statement::ddl::get_kafka_sink_consistency_config [−][src]
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>
Expand description
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.