一种自定义处理器，它以简单的方式缓冲事件 java.util.List 在 process() -此缓冲区不是状态存储区。
每30秒一次， punctuate() 将此列表排序并刷新到Flume。假设只有一个分区源和汇。需要eos处理保证。
我也知道在任何时候 process() 被执行或 punctuate() 被执行。
我担心这个缓冲区没有得到changelog主题的支持。理想情况下，我认为这应该是一个支持eos的状态存储。
但有一种观点认为 commit.interval 超过30秒（例如40秒）将确保缓冲区中的事件不会丢失。而且因为我们使用 WALL_CLOCK_TIME ，的 punctuate() 无论我们是否有事件，总是每30秒调用一次。
这是一个有效的论点吗？这里有哪些情况会使缓冲区中的事件永远丢失？

@Override
public void init(ProcessorContext processorContext) {
    super.init(processorContext);
    this.buffer = new ArrayList<>();
    context().schedule(Duration.ofSeconds(20L), PunctuationType.WALL_CLOCK_TIME, this::flush);
}

void flush(long timestamp){
    LOG.info("Punctuator invoked.....");
    buffer.stream().sorted(Comparator.comparing(o -> o.getId())).forEach(
            i -> context().forward(i.getId(), i)
    );
}

@Override
public void process(String key, Customer value) {
    LOG.info("Processing {}", key);
    buffer.add(value);
}