我是分组输入数据的基础上的关键，然后做1分钟窗口30秒跳和在聚合器。
数据正在被一个应用程序发送和使用，对这个应用程序的需求可能会在未来发展，因此，我认为未来需要灵活性和快速变化。
当前逻辑描述如下：

@StreamListener("input")
    public void process(KStream<String, Data> DataKStream) {

        JsonSerde<DataAggregator> DataJsonSerde =
                new JsonSerde<>(DataAggregator.class);

        DataKStream
                .groupByKey()
                .windowedBy(TimeWindows.of(60000).advanceBy(30000))
                .aggregate(
                        DataAggregator::new,
                        (key, Data, aggregator) -> aggregator.add(Data),
                        Materialized.with(Serdes.String(), DataJsonSerde)
                );
    }
DataAggregator.java

public class DataAggregator {

    private List<String> dataList = new ArrayList<>();

    public DataAggregator add(Data data) {
        dataList.add(data.getId());
        System.out.println(dataList);
        return this;
    }

    public List<String> getDataList() {
        return dataList;
    }
}

然而，鉴于不断发展的需求，我想给用户的可能性，改变通过菜单的逻辑。
例如，用户可以随意更改窗口或更改数据隔离的方式。
我可能在考虑编写几个java类，当用户选择特定选项时，这些类可以打开和关闭。
但我想知道是否可以做些更好、更有活力的事情。