在满足条件之前，如何处理一条消息而不让消息离开队列？

Question

这是关于一个特定的用例，我计划通过flink流来解决这个用例。

一个消息被发送到flink流处理，流被键控，从而得到预期的分区。然而，每个密钥的每个消息都需要评估，直到满足一个条件为止，例如，假设有一个银行系统，其中一个帐户的帐户交易（消息）需要按顺序处理，并且不可能处理不按顺序处理的消息，因为它将导致不一致的系统状态。系统需要等待一条消息被处理（甚至可能超过2-3天），然后再按顺序处理下一条消息。如何在flink中实现这一点，而不阻塞与其他密钥相关联的消息处理的任何部分？

Answer 1

你看过CEP图书馆了吗？您可以指定如下模式：

Pattern<Event, ?> pattern = Pattern.<Event>begin("firstOfSequence").where(new FilterFunction<Event>() {
    private static final long serialVersionUID = 5726188262756267490L;

    @Override
    public boolean filter(Event value) throws Exception {
        return value.isFirstOfSequence();
    }
}).followedBy("secondOfSequence").where(new FilterFunction<Event>() {
    private static final long serialVersionUID = 5726188262756267490L;

    @Override
    public boolean filter(Event value) throws Exception {
        return value.isSecondOfSequence();
    }
});