confluent-kafkaのプロデューサ設定

Question

confluent-kafkaを使用してプロデューサを作成するときに、保持時間を設定する方法がドキュメントに見つかりませんでした。

「bootstrap-servers」と指定した場合、デフォルトの保持時間は1日です。私はそれを変えたいと思っています。

（私はこれをコマンドラインではなくPython APIで行います） ありがとうございました。

Answer 1

保持時間はプロデューサーの所有物ではありません。 デフォルトの保持時間は、ブローカーコンフィグファイルserver.propertiesに設定され、プロパティはlog.retention.hoursなどです。 /etc/kafka/server.properties ...インストールによって異なります。

トピックベースごとに保持時間を変更することができます。

$ <path-to-kafka>/bin/kafka-topics.sh --zookeeper <zookeeper-quorum> --alter --topic <topic-name> --config retention.ms=<your-desired-retention-in-ms> 

HTH ....