server.propertiesのトピックごとのKafkaログ保持時間

Question

私はKafkaトピックの1つの保持期間を短縮したいと思います。トピックの残りの部分ではデフォルトの保持時間（7日間）を使用したいと考えています。 ターミナル：bin/kafka-topics.sh --zookeeper XXX --alter --topic XXXX --config retention.ms=86400000で設定できることがわかりました。 これは、server.propertiesに設定され、今後使用できるようにするための方法があるかどうか疑問に思っていました。たとえば、デフォルトの保持時間については、log.retention.minutes = XXXです。

EDIT：いくつかの調査の後、トピックごとの構成をZK（https://issues.apache.org/jira/browse/KAFKA-554）で行う方がよいことに気付きました。しかし、私はまだkafka-topics.shを使用するのではなく、プログラムでこれを行うことができるかどうかは疑問です。

Answer 1

トピックの保持時間が異なる場合は、kafka-topics.shを使用してトピックを作成するときに指定する必要があります。

server.propertiesでは、上書きのないすべてのトピックに適用される設定のみ指定できます。

Answer 2

https://kafka.apache.org/0110/javadoc/index.html?org/apache/kafka/clients/admin/AdminClient.htmlを使用すると、独自のプログラムソリューションを作成することができますが、私にはカフカの設定があるとは思われません。 https://github.com/yahoo/kafka-managerのようなツールを使用することもできます。