Function spawn_metadata_thread

fn spawn_metadata_thread<C: ConsumerContext>(
    config: RawSourceCreationConfig,
    consumer: BaseConsumer<TunnelingClientContext<C>>,
    topic: String,
    tx: UnboundedSender<(Timestamp, MetadataUpdate)>,
)