Module sink 

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.

Functions

overcompacted_error 🔒

Formats the error reported when a sink’s input has been compacted past the upper the sink last committed, so the sink can never resume. remedy tells the user how to recover, which differs by sink type.