Function encode 

pub async fn encode(
    value: &Value,
    format: &KafkaValueFormat,
    sr_client: Option<&SchemaRegistryClient>,
    schema_ctx: &SchemaContext,
) -> Result<Vec<u8>, FaucetError>

Available on crate feature sink-kafka only.