开发者社区> 问答> 正文

消息队列Kafka如何创建消息不过期的Topic

已解决

消息队列Kafka如何创建消息不过期的Topic

展开
收起
提个问题 2024-06-14 13:12:47 35 0
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答
    使用Local存储引擎,在创建Topic页面选择日志清理策略为Compact。
    Log Compaction清理策略保证相同Key的消息,最新的value值一定会被保留。
    主要适用于系统宕机后恢复状态,系统重启后重新加载缓存等场景。
    例如,在使用Kafka Connect或Confluent Schema Registry时,需要使用Kafka Compact Topic存储系统状态信息或配置信息。
    Compact Topic一般用于生态组件,使用不当会导致磁盘打满而宕机,请谨慎使用。
    2024-06-14 13:12:48
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载