Module mz_storage_client::sink

Modules

• progress_key

Structs

• TopicConfig
  Configuration of a topic created by ensure_kafka_topic.

Enums

• TopicCleanupPolicy
  Describes how to clean up old data in the topic.

Functions

• ensure_kafka_topic
  Ensures that the named Kafka topic exists.
• publish_kafka_schemas
  Publish value and optional key schemas for a given topic.