馬仕兵Shiro安全框架
while (true) {
? ? ?System.out.println("運(yùn)行中......");
? ? ?Long lastModifiedKey = aggRecordMap.getOrDefault(lastMsgTimeKey, 0L);
? ? ?if (lastModifiedKey > 0 && System.currentTimeMillis() - lastModifiedKey > windowSize.toMillis()) {
? ? ? ?producer.send(new ProducerRecord<>(SOURCE_TOPIC, lastModifiedKey.toString(), signal));
? ? ?}
標(biāo)簽：
