Module sink 

Modules

progress_key

Functions

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.