fn get_kafka_sink_consistency_config(
scx: &StatementContext<'_>,
topic_name: &str,
sink_format: &KafkaSinkFormat,
consistency: Option<KafkaConsistency<Aug>>
) -> Result<Option<(String, KafkaSinkFormat)>, PlanError>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.