飞滴出行网约车项目2022版

   Duration windowSize = Duration.ofSeconds(10);    Materialized<String, List<String>, WindowStore<Bytes, byte[]>> storeMaterialized = Materialized.<String, List<String>, WindowStore<Bytes, byte[]>>as(            "").withKeySerde(stringSerde).withValueSerde(jsonSerde)        .withRetention(Duration.ofMinutes(5));    ConcurrentHashMap<String, Long> aggRecordMap = new ConcurrentHashMap<>();    String lastMsgTimeKey = "lastMsgTimeKey";    String signal = "signal";