support ingest stream