fixup! fixup! add global aggregate consumer