merge(sampling(), samplingCheckFlow()).flowOn(context)
private fun samplingCheckFlow() : Flow<String> {
  return flow<String> {
    <http://Log.info|Log.info>().log("cehcking flow!")
    while(isSampling.get()) { delay(1000L) }
    <http://Log.info|Log.info>().log("[kafka sampling] - throw cancellation")
    throw CancellationException("not sampling")
  }
}