Filebeat to kafka -监视

Question

我有文件传输给卡夫卡。请您告诉我，我如何监控这个流量和发送allert时，没有新的数据卡夫卡超过20分钟，例如。

• ，你知道卡夫卡的一些指标吗？
• ，我怎么能直接在上面的contex中监视文件?

Answer 1

我有两种方法。第一个是简单的，不需要额外的努力。它可能很有用。因此，首先，您可以向主题发送带有时间戳的数据。然后，查找主题中的最后一个数据时间戳。它会给你一些关于时机的信息。如果我需要谈第二个问题，当然，这比我前面解释的更专业。但是它需要更多关于Kafka和Kafka的信息。是!阿帕奇卡夫卡流！对于警报机制、聚合和其他一些东西来说，不仅仅是消费，还有很多有用的东西。您可以使用窗口，特别是会话窗口，这将是解决方案的最佳选择。