Module coord::sink_connector[−][src]

Functions

build
build_avro_ocf
build_kafka
publish_kafka_schemas

Publish value and optional key schemas for a given topic.

register_kafka_topic