Function mz_storage::source::kafka::spawn_metadata_thread

source ยท 
fn spawn_metadata_thread<C: ConsumerContext>(
    config: RawSourceCreationConfig,
    consumer: BaseConsumer<TunnelingClientContext<C>>,
    topic: String,
    poll_interval: Duration,
    tx: UnboundedSender<MetadataUpdate>,
)