开发者社区 问答 正文

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

已解决

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

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

    评论

    全部评论 (0)

    登录后可评论