Module sink

Modules§

await_glue_schema_version_available 🔒: Wait until Glue reports the schema version registered as Available, returning its id.
discover_topic_configs 🔒
ensure_kafka_topic: Ensures that the named Kafka topic exists.
glue_compatibility_from_csr: Map a Confluent compatibility level onto its AWS Glue equivalent.
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.
warn_on_glue_compatibility_mismatch 🔒: Warn if the schema’s existing compatibility differs from desired.