马老师SpringCloud Alibaba 实战与源码深入剖析

 .aggregate(() -> new ArrayList<>(), (k, v, agg) -> {          System.out.println("========== aggregate record ==========");          log.info("k: {}, v: {}, agg: {}", k, v, agg);          if (!signal.equals(v)) {            agg.add(v);          }          aggRecordMap.put(lastMsgTimeKey, System.currentTimeMillis());          return agg;