Ingest data from Message Hub in a Streams flow