开发者社区> 问答> 正文

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

已解决

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

展开
收起
提个问题 2024-06-14 13:12:47 39 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
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
企业互联网架构之消息队列 立即下载
基于消息队列RocketMQ的大型分布式应用上云最佳实践 立即下载
云原生消息队列Apache RocketMQ 立即下载