Module sink 

Modules

progress_key

Functions

ensure_kafka_topic

Ensures that the named Kafka topic exists.

publish_glue_schema

Register schema for a sink in an AWS Glue Schema Registry, returning the schema-version UUID to frame records with.

publish_kafka_schema

Publish a schema for a given subject, and set compatibility levels for the schema if applicable.