此配置必须删除,否则

发布时间:2025-06-24 16:35:39  作者:北方职教升学中心  阅读量:482


如果没有消费,kafka-操作。

还需要检查当前的kafkakakaka topic对应的分区副本(假设单分区单副本)大小,验证数据是否已被删除。

[root@localhost ~]# du -sh /export/server/kafka/logs/kafka/topicName-0。

此配置必须删除,否则,

2.2 添加数据过期时间配置。

将过期时间设置为1秒。

某topic测试环境的数据格式发生了变化,原始数据需要清空并重新生产。证明数据已清理干净。

2.4 删除过期时间配置。
但最好在官方网站上阅读哈:

kafka-配置。
本博客详细描述了kafka管理脚本的实际使用,我测试了几个是正确的,如果您感兴趣,

2、

1、

配置控制󿀌例如,
Kafka——详细说明管理Kafka(命令行工具)。

2.1 检查当前topic的配置。

[root@localhost ~]# du -sh  /export/server/kafka/logs/kafka/topicName-068M /export/server/kafka/logs/kafka/topicName-0。借鉴内容。后续数据可能会在消费前被删除。背景。

[root@localhost ~]# /export/server/kafka/bin/kafka-configs.sh --zookeeper x.x.x.x:2181 --entity-type topics --entity-name topicName --describe。同时需要注意server.properties中。
2.3 已删除检查数据。

[root@localhost ~]# /export/server/kafka/bin/kafka-configs.sh --zookeeper x.x.x.x:2181 --entity-type topics --entity-name topicName --alter --delete-config retention.ms。后续数据可能会被删除。操作。可以验证。

[root@localhost ~]# /export/server/kafka/bin/kafka-configs.sh --zookeeper  x.x.x.x:2181 --entity-type topics --entity-name topicName  --alter --add-config retention.ms=1000。

2.3 已删除检查数据。
3、
log.retention.check.interval.ms。我的配置是5分钟:300000,所以最长要等5分钟才能看到结果。
直到文件夹显示大小为20K,

此配置必须删除,否则,