如何解决Filebeat到Kafka-监视
我有filebeat可以将数据发送到kafka。 您能否告诉我,例如,当kafka中没有新数据超过20分钟时,如何监控此流程并发送allert。
- 您知道一些卡夫卡指标吗?
- 如何直接在上面的contex中监视filebeat?
解决方法
我有两种方法。第一个很简单,不需要额外的努力。它很有用。因此,首先,您可以将带有时间戳的数据发送到主题。然后,查找主题中的最后一个数据时间戳。它会给你一些关于时间的信息。 如果我需要谈论第二个,当然它比我上面解释的更专业。但它需要更多关于 Kafka 和 Kafka Streams API 的信息。 是的! Apache Kafka 流!对于警报机制,聚合和一些不同的东西比仅仅消耗有用得多。您可以使用窗口化,特别是会话窗口化最适合您的解决方案。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。