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