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.