Nar*_*ari 5 apache-kafka kafka-consumer-api
我们的用例是从kafka删除陈旧/未使用的主题，即，如果某个主题（在所有分区上）在过去7天中没有任何新消息，则我们将其视为陈旧/未使用并删除它。
许多Google搜索结果建议为邮件添加时间戳，然后对其进行解析。对于新的主题和消息，可以使用灵魂化功能，但是我们现有的主题和消息中没有任何时间戳。
我该如何工作？
| 归档时间： |
|
| 查看次数： |
1723 次 |
| 最近记录： |