Module sink

Source
Expand description

Moving data to external systems

Modulesยง

iceberg ๐Ÿ”’
Iceberg sink implementation.
kafka ๐Ÿ”’
Code to render the sink dataflow of a KafkaSinkConnection. The dataflow consists of two operators in order to take advantage of all the available workers.