问题现象:

    kafka中有些topic的数据存储比较大,需要对某个topic数据的保留时间设置短一些

    配置方式

     比如ee有一个topic 数据存储比较大,easyegle_hdfs_audit_ndh_uat_hdfs

    先kafka web页面找到对应的topic

    FAQ—topic级别的数据时间配置 - 图1

    点击右边的Update config

    FAQ—topic级别的数据时间配置 - 图2

    cleanup.policy 配置成delete

    FAQ—topic级别的数据时间配置 - 图3

    retention.ms配置对应的保留时间(单位:毫秒) 这里配置的是43200000 保留12小时

    FAQ—topic级别的数据时间配置 - 图4

    点击保存

    FAQ—topic级别的数据时间配置 - 图5

    topic可以看到配置的对应的参数

    FAQ—topic级别的数据时间配置 - 图6