卡夫卡轮定时器

作者: 無口君
发布时间: 2024-12-20 02:26:08 (1月前)
转自：

3 条回复

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

<div class =“post-text”itemprop =“text”> <P> 您可以近距离观看Kafka Streams图书馆。 <a href="https://kafka.apache.org/21/documentation/streams/developer-guide/dsl-api.html" rel="nofollow noreferrer"> https://kafka.apache.org/21/documentation/streams/developer-guide/dsl-api.html </A> ， <a href="https://kafka.apache.org/21/documentation/streams/developer-guide/processor-api.html" rel="nofollow noreferrer"> https://kafka.apache.org/21/documentation/streams/developer-guide/processor-api.html </A> 。 </p> <P> 使用Kafka Streams，您可以完成许多复杂的事件处理工作。处理器API是更低级别的API，为您提供更大的灵活性，将每个处理消息放入状态存储（Kafka Streams抽象，即复制到changelog主题），然后使用 <code> Punctuator </code> 你可以查看邮件 <EM> 过期 </EM> 。 </p> </DIV>

编辑
1#
回复此人
句号了哦哦 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 关于你最初的问题： </p> <BLOCKQUOTE> <P> 我想知道kafka队列是否可以保存数据几秒钟而不是释放数据 </p> </BLOCKQUOTE> <P> 你可以设置 <code> log.cleanup.policy </code> 如 <code> delete </code> （这是默认值）并更改 <code> retention.ms </code> 从默认 <code> 604800000 </code> （1周）到 <code> 10000 </code> 。 </p> <P> 你能再次解释一下你想要检查的其他内容，以及你之后的意思 <code> Regards </code> 部分？ </p> </DIV>

编辑

登录后才能参与评论