在Kafka0.9中安装小型retention_ms不起作用

Question

我想将小retention_ms设置为1200000，以消除初始的脏负载。

json是完全正确的，因为它不工作，此外，我还尝试设置其他参数。然而，我的消费者仍然可以获取两周前存在的数据。

 {"config": {"segment.ms": "1200000", "retention.ms": "1200000", "cleanup.policy": "delete", "segment.jitter.ms": "1200000", "delete.retention.ms": "1200000", "min.cleanable.dirty.ratio": "0.01"}, "version": 1}

总之，我想知道默认的retention.ms是7天，但是我的用户可以最早在7天内用autooffser.reset访问数据，

卡夫卡忽视我的retention.ms的原因是什么？

Answer 1

在阅读了源代码https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/admin/AdminUtils.scala#L492之后，

Kafka通过在动物园管理员中存储更改通知来更新主题的配置。所以问题是在/config/topics中存储配置json是不够的，您也需要将json存储在/config/changes中。