我配置了esper处理器来监听kafka中的消息。通常 select * from events.win:time(2 min) 现在将触发过去2分钟内的所有事件，如果在过去2分钟内Kafka没有消息，我想触发通知。当我写这样的东西时，我该怎么处理呢 select * from events(Ip='1.1.1.1').win:time(2 min) 这将没有匹配的消息/事件，并且esper没有触发。如果在给定的时间内没有事件，我应该如何触发esper提前谢谢
select * from events.win:time(2 min)
select * from events(Ip='1.1.1.1').win:time(2 min)
yh2wf1be1#
你能做到的
select * from pattern [every (timer:interval(2 min) and not MyEvent)]
//提示：不要把你的事件称为“events”，称它为有用的东西并使用大写字母
1条答案
按热度按时间yh2wf1be1#
你能做到的
//提示：不要把你的事件称为“events”，称它为有用的东西并使用大写字母