马老师drools规则引擎

 Materialized<String, List<String>, WindowStore<Bytes, byte[]>> storeMaterialized = Materialized.<String, List<String>, WindowStore<Bytes, byte[]>>as(            "time-windowed-aggregated-stream-store").withKeySerde(stringSerde).withValueSerde(jsonSerde)        .withRetention(Duration.ofMinutes(5));