조건이 충족 될 때까지 대기열을 나가는 메시지없이 메시지를 처리하는 방법은 무엇입니까?

Question

이것은 flink 스트리밍을 통해 해결할 계획 인 특정 사용 사례에 관한 것입니다.

메시지가 flink 스트림 처리로 보내지면 스트림이 입력되고 예상대로 분할됩니다. 그러나 키 당 각 메시지는 조건이 충족 될 때까지 평가되어야합니다. 계정에 대한 계정 트랜잭션 (메시지)을 순서대로 처리해야하는 은행 시스템이 있으며 일관성없는 시스템 상태로 이어질 수 있으므로 순서가 잘못된 메시지를 처리 ​​할 수는 없다고 말할 수 있습니다. 시스템은 순서대로 다음 메시지를 처리하기 전에 메시지 처리를 기다려야합니다 (2 ~ 3 일 이상). 다른 키와 관련 될 수있는 메시지 처리의 일부를 차단하지 않으면 서 어떻게 구현할 수 있습니까?

미리 감사드립니다.

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(); 
    } 
});