Kafka 卡夫卡轮定时器 返回

卡夫卡轮定时器


無口君
2025-03-20 09:02:10 (15天前) 
  1.             美好的一天，

我想知道是否

卡夫卡
</跨度>
队列可以保存数据几秒钟而不是释放数据。

我收到一条消息

卡夫卡
</跨度>
话题，
在解析数据之后，我将它保存在内存中……一段时间（10秒）（这会产生独特的消息），每条消息都有自己的计时器），我想要

卡夫卡
</跨度>
告诉我该消息已过期（10秒），以便我可以……

3 条回复
  1. 0# 庸人自扰1 | 2019-08-31 10-32



    您可以近距离观看Kafka Streams图书馆。

    https://kafka.apache.org/21/documentation/streams/developer-guide/dsl-api.html

    ，

    https://kafka.apache.org/21/documentation/streams/developer-guide/processor-api.html

    。



    使用Kafka Streams，您可以完成许多复杂的事件处理工作。处理器API是更低级别的API，为您提供更大的灵活性，将每个处理消息放入状态存储（Kafka Streams抽象，即复制到changelog主题），然后使用

    Punctuator

    你可以查看邮件

    过期

    。


  2. 1# 句号了哦哦 | 2019-08-31 10-32



    关于你最初的问题：




    我想知道kafka队列是否可以保存数据几秒钟而不是释放数据




    你可以设置

    log.cleanup.policy

    如

    delete

    （这是默认值）并更改

    retention.ms

    从默认

    604800000

    （1周）到

    10000

    。



    你能再次解释一下你想要检查的其他内容，以及你之后的意思

    Regards

    部分？


登录 后才能参与评论