@Override
    public List<InLongMessage> intercept(List<InLongMessage> messages) {
        if (CollectionUtils.isEmpty(messages)) {
            return new ArrayList<>(0);
        }
        return messages.stream()
                .filter(msg -> isValidMsgTime(msg.getMsgTime()))
                .collect(Collectors.toList());
    }
The sdk interceptor that use to filter messages do not in the time interval.
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/interceptor/MsgTimeInterceptor.java