gpt4 book ai didi

apache-kafka - 卡夫卡 : How to get last modified time for a topic i. e.添加到主题任何分区的最后一条消息

转载 作者:行者123 更新时间:2023-12-04 21:38:55 25 4
gpt4 key购买 nike

我们的用例是从 kafka 中删除陈旧/未使用的主题,即如果主题(在所有分区上)在过去 7 天内没有任何新消息,那么我们会将其视为陈旧/未使用并删除它。

许多谷歌结果建议在消息中添加时间戳,然后对其进行解析。对于新的主题和消息,soultion 会起作用,但我们现有的主题和消息中没有任何时间戳。

我怎样才能让它工作?

最佳答案

kafka.api.OffsetRequest.LatestTime()将返回添加到队列的最新消息。您可以使用 Simple Consumer API确定要读取的偏移量。

更多详情请查看 wiki

关于apache-kafka - 卡夫卡 : How to get last modified time for a topic i. e.添加到主题任何分区的最后一条消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31735852/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com