Module sink

Modules

• progress_key

Structs

• TopicConfigs 🔒

Functions

• discover_topic_configs 🔒
• ensure_kafka_topic
  Ensures that the named Kafka topic exists.
• publish_kafka_schema
  Publish a schema for a given subject, and set compatibility levels for the schema if applicable.