apache-kafka - Kafka:每 1GB 自动刷新数据
问题描述
我必须为自动删除或自动清除 Kafka 代理中某个主题的数据设置哪个属性。
我尝试编辑以下属性,但没有任何区别。
log.retention.ms
log.retention.byte
log.retention.check.interval.ms
但是,只要达到 1 GB,它就不会删除刷新所以,在下面的属性和上面的属性中未注释
log.flush.interval.messages
log.flush.interval.ms
我可以将这些属性的值增加多少,它正在删除最大 180 MB 左右的数据。
如何在特定主题的数据达到 1GB 时自动删除数据。
解决方案
log.retention.ms和log.retention.bytes是代理的属性,在创建主题时用作默认值。当您使用 kafka-topics.sh 更改当前正在运行的主题的配置时,您应该指定一个主题级别的属性。
日志保留时间的主题级属性是retention.ms和retention.bytes。
尝试以下命令按时间设置保留:
bin/kafka-topics.sh --zookeeper zk.yoursite.com --alter --topic as-access --config retention.ms=86400000
尝试以下命令按大小设置保留:
bin/kafka-topics.sh --zookeeper zk.yoursite.com --alter --topic as-access --config retention.bytes=1048576
验证属性是否设置为主题的命令:
bin/kafka-topics.sh --describe --zookeeper zk.yoursite.com --topic as-access
然后你会看到类似下面的东西。
主题:as-access PartitionCount:3 ReplicationFactor:3 Configs:retention.ms=86400000
推荐阅读
- node.js - sh:1:rimraf:实时服务器上的权限被拒绝问题
- c# - 在 foreach 循环中为对象赋值
- php - 为什么 $conigf['quality'] 参数不能与 png 文件一起使用,但在 codeigniter 中上传图像时与 jpg 一起使用很棒?
- python - 如何将 django 管理员更改列表导出为 csv
- geoserver - 我可以在 GeoServer 中打开 HDF4 或 5 文件吗?
- mysql - 带有 DATE_ADD() 函数的语法错误的 SQL 查询(已编辑)
- reactjs - reactjs钩子中页面刷新时丢失身份验证状态
- python - 尝试为 Google 存储收集 Google 默认凭据时出现 DefaultCredentialsError
- arrays - 如何在 PowerPoint 中使用 VBA 将用户窗体文本框中输入的变量转换为模块中的数组文本?
- tcp - F-stack Client 未连接到 F-stack Server