apache-kafka - 保存期間で Apache Kafka メッセージをフィルタリングすることはできますか?

Question

抽象的な観点から見ると、Apache Kafka はデータをトピックに格納します。このデータは、消費者によって読み取られる可能性があります。

特定の年齢のデータをgrepsする（モニター）コンシューマーが欲しいです。モニターは、レコードがまだ未読であり、保持時間に達すると Kafka によって破棄されるという警告をサブシステムに送信する必要があります。

今まで適切な方法を見つけることができませんでした。