Function dataflow::sink::kafka::kafka

fn kafka<G>(
    collection: Collection<G, (Option<Row>, Option<Row>)>, 
    id: GlobalId, 
    connector: KafkaSinkConnector, 
    key_desc: Option<RelationDesc>, 
    value_desc: RelationDesc, 
    as_of: SinkAsOf, 
    write_frontier: Rc<RefCell<Antichain<Timestamp>>>, 
    metrics: &KafkaBaseMetrics
) -> Rc<dyn Any> where
    G: Scope<Timestamp = Timestamp>,