kafka 0.9の小さいretention_msが動作していません

Question

retention_msを1200000と小さく設定して初期汚れを取り除くことがあります。

jsonは完全に正しいですが、機能しないため、さらに私は他のパラメータを設定しようとします。しかし、私の消費者はまだ2週間前に存在するデータを取り出すことができます。

{"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日であるが、データに到達することができ、私の消費者は、早いようautooffser.resetと7日には存在し

とどうなりますかカフカが私のretention.msを無視する理由？

Answer 1

ソースコードhttps://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/admin/AdminUtils.scala#L492を読んだ後、

カフカは、飼育係の変更の通知を格納することによって、トピックの設定を更新します。だから問題は、/config/topicsの設定jsonを格納するだけでは十分ではない、あなたも同様に動物園で/config/changesにjsonを格納する必要があります。