kafka删除主题数据和删除主题
2018-01-08 10:34
1086 查看
kafka使用confluent-3.1.2 删除的主题名:test
数据删除后,继续使用主题,那主题数据的保留时间就不可能为三秒,所以把上面修改的配置删掉,采用server.properties里面统一的配置。
1、删除主题
在server.properties中增加设置,默认未开启delete.topic.enable=true删除主题命令
/bin/kafka-topics --delete --topic test --zookeeper localhost:2181
2、删除主题数据
如果想保留主题,只删除主题现有数据(log)。可以通过修改数据保留时间实现bin/kafka-configs --zookeeper localhost:2181 --entity-type topics --entity-name test --alter --add-config retention.ms=3000 //修改保留时间为三秒,但不是修改后三秒就马上删掉,kafka是采用轮训的方式,轮训到这个主题发现三秒前的数据都是删掉。时间由自己在server.properties里面设置,设置见下面。
数据删除后,继续使用主题,那主题数据的保留时间就不可能为三秒,所以把上面修改的配置删掉,采用server.properties里面统一的配置。
bin/kafka-configs --zookeeper localhost:2181 --entity-type topics --entity-name test --alter --delete-config retention.msserver.properties里面数据保留时间的配置
log.retention.hours=168 //保留时间,单位小时 log.retention.check.interval.ms=300000 //保留时间检查间隔,单位毫秒
相关文章推荐
- 使用Java API创建(create),查看(describe),列举(list),删除(delete)Kafka主题(Topic)
- 大数据_Kafka_Kafka自动创建不存在的Topics / 删除已存在的Topics
- kafka删除topic及其相关数据
- zookeeper删除kafka元数据,解决kafka无法消费数据的问题
- kafka 数据删除策略
- 使用Java API创建(create),查看(describe),列举(list),删除(delete)Kafka主题(Topic)--转载
- Kafka误删zk元数据,全部删除(仅限测试环境)
- 使用Java API创建(create),查看(describe),列举(list),删除(delete)Kafka主题(Topic)
- 主题:Mybatis3.0查询,保存,更新,删除数据。
- 使用Java API创建(create),查看(describe),列举(list),删除(delete)Kafka主题(Topic)
- 使用Java API创建(create),查看(describe),列举(list),删除(delete)Kafka主题(Topic)--转载
- 使用Java API创建(create),查看(describe),列举(list),删除(delete)Kafka主题(Topic)--转载
- kafka数据量快速循环增加删除问题
- oracle学习 六 删除表空间,数据文件的语句以及导入导出dmp文件的方法(持续更新中)
- U盘数据删除了怎么恢复
- Oracle12C--主外键约束删除数据问题--级联操作(九)
- oracle bbed恢复删除数据实例
- Solr4.3---4.6删除数据的办法
- 域控制器降级失败后删除数据的方法
- 删除数据表字段删除ID