小编Sud*_*kar的帖子

请在下面找到我创建并打算用作自定义对象的类.

public class SelfExpiringObject {

    private boolean expired;
    // other properties

    public void setValidity(final int seconds) {
        new Timer().schedule(new TimerTask() {
            public void run() {
                expired = true;
            }
        }, TimeUnit.SECONDS.toMillis(seconds));
    }

    public boolean isExpired() {
        return expired;
    }
}

任何人都可以建议的更好的选择吗？

想在规则引擎中使用它来处理事件.其中一个场景是收到事件时,将它们放入会话中(使用具有自失效属性的对象).我希望他们只根据规则中设置的有效性进入会话.一旦它们到期,它们将被从会话中删除.

是否可以验证/过滤发送到Kafka主题的消息？

就像,我想确保只有有效的客户端/生产者向我的主题发送消息.我当然可以通过根据某些参数/标准丢弃无效消息来在消费者方面进行验证.但是,如果我想在将消息写入主题之前执行该操作,该怎么办？

比如说,Kafka会收到一条消息,执行一些验证,然后决定是否需要丢弃或将该消息写入主题.这可能吗？