0

我已将 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

提前致谢

4

1 回答 1

1

你可以这样做

select * from pattern [every (timer:interval(2 min) and not MyEvent)]

// 提示：不要称你的事件为“事件”，称它为有用的东西并使用大写

于 2017-09-11T13:07:48.323 回答