问题描述
我有filebeat可以将数据发送到kafka。 您能否告诉我，例如，当kafka中没有新数据超过20分钟时，如何监控此流程并发送allert。
- 您知道一些卡夫卡指标吗？
- 如何直接在上面的contex中监视filebeat？
解决方法
我有两种方法。第一个很简单，不需要额外的努力。它很有用。因此，首先，您可以将带有时间戳的数据发送到主题。然后，查找主题中的最后一个数据时间戳。它会给你一些关于时间的信息。 如果我需要谈论第二个，当然它比我上面解释的更专业。但它需要更多关于 Kafka 和 Kafka Streams API 的信息。 是的！ Apache Kafka 流！对于警报机制，聚合和一些不同的东西比仅仅消耗有用得多。您可以使用窗口化，特别是会话窗口化最适合您的解决方案。