Function ensure_kafka_topic

pub async fn ensure_kafka_topic(
    connection: &KafkaSinkConnection,
    storage_configuration: &StorageConfiguration,
    topic: &str,
    __arg3: &KafkaTopicOptions,
    ensure_topic_config: EnsureTopicConfig,
) -> Result<bool, Error>

Ensures that the named Kafka topic exists.

If the topic does not exist, the function creates the topic with the provided config. Note that if the topic already exists, the function does not verify that the topic’s configuration matches config.

Returns a boolean indicating whether the topic already existed.