fixup! add global aggregate consumer