docs: public boolean track(TopologyAPI.StreamId stream, long ts) {
      Long currentVal = streamToTs.get(stream);
      if (currentVal == null || ts > currentVal) {
        streamToTs.put(stream, ts);
      }
      return ts >= lastWaterMarkTs;
    }