马仕兵Shiro安全框架

while (true) {      System.out.println("运行中......");      Long lastModifiedKey = aggRecordMap.getOrDefault(lastMsgTimeKey, 0L);      if (lastModifiedKey > 0 && System.currentTimeMillis() - lastModifiedKey > windowSize.toMillis()) {        producer.send(new ProducerRecord<>(SOURCE_TOPIC, lastModifiedKey.toString(), signal));      }