add test for coordinator stream system producer