Function encode_collection

fn encode_collection<G: Scope>(
    name: String,
    input: &Collection<G, (Option<Row>, DiffPair<Row>), Diff>,
    envelope: SinkEnvelope,
    connection: KafkaSinkConnection,
    storage_configuration: StorageConfiguration,
) -> (Collection<G, KafkaMessage, Diff>, Stream<G, HealthStatusMessage>, PressOnDropButton)

Encodes a stream of (Option<Row>, Option<Row>) updates using the specified encoder.

Input Row updates must me compatible with the given implementor of Encode.