Function coord::timestamp::rt_kafka_metadata_fetch_loop

fn rt_kafka_metadata_fetch_loop(
    c: RtKafkaConnector, 
    consumer: BaseConsumer<MzClientContext>, 
    wait: Duration, 
    metrics: &Metrics
)