kafka动态修改日志保存时间

kafka动态修改日志保存时间

查看

bin/kafka-configs.sh --describe --zookeeper zk01.td.com:2181 --entity-type topics --entity-name flink_clickhouse_test

修改

bin/kafka-configs.sh --zookeeper zk01.td.com:2181 --alter --entity-name flink_bitmap --entity-type topics --add-config retention.ms=86400000