Function encode_collection 

fn encode_collection<'scope, T: Timestamp>(
    name: String,
    input: VecCollection<'scope, T, (Option<Row>, DiffPair<Row>), Diff>,
    envelope: SinkEnvelope,
    connection: KafkaSinkConnection,
    storage_configuration: StorageConfiguration,
) -> (VecCollection<'scope, T, KafkaMessage, Diff>, StreamVec<'scope, T, 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.